diff --git a/hivemind_etl/simple_ingestion/pipeline.py b/hivemind_etl/simple_ingestion/pipeline.py index 2e763e0..65fbf02 100644 --- a/hivemind_etl/simple_ingestion/pipeline.py +++ b/hivemind_etl/simple_ingestion/pipeline.py @@ -11,7 +11,7 @@ @workflow.defn -class IngestionWorkflow: +class VectorIngestionWorkflow: """A Temporal workflow for processing document ingestion requests. This workflow handles the orchestration of document processing activities, diff --git a/registry.py b/registry.py index 5a7a412..3a9020b 100644 --- a/registry.py +++ b/registry.py @@ -20,7 +20,7 @@ WebsiteIngestionSchedulerWorkflow, MediaWikiETLWorkflow, PlatformSummariesWorkflow, - IngestionWorkflow, + VectorIngestionWorkflow, RealTimeSummaryWorkflow, ) @@ -29,7 +29,7 @@ WebsiteIngestionSchedulerWorkflow, MediaWikiETLWorkflow, PlatformSummariesWorkflow, - IngestionWorkflow, + VectorIngestionWorkflow, RealTimeSummaryWorkflow, ] diff --git a/workflows.py b/workflows.py index dd53b85..f8b7484 100644 --- a/workflows.py +++ b/workflows.py @@ -11,7 +11,7 @@ MediaWikiETLWorkflow, ) from hivemind_etl.simple_ingestion.pipeline import ( - IngestionWorkflow, + VectorIngestionWorkflow, ) from hivemind_summarizer.summarizer_workflow import PlatformSummariesWorkflow from hivemind_summarizer.real_time_summary_workflow import RealTimeSummaryWorkflow