updated main orchestration flow

open-politics · Dec 31, 2024 · 56490cb · 56490cb
1 parent 74703e7
commit 56490cb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/opol/stack/flows/orchestration/orchestration.py b/opol/stack/flows/orchestration/orchestration.py
@@ -21,7 +21,7 @@ async def produce_flags(raise_on_failure=True):
     return response.status_code == 200
 
 @task
-async def create_scrape_jobs(raise_on_failure=True):
+async def scrape_sources(raise_on_failure=True):
     async with httpx.AsyncClient(timeout=1000) as client:
         response = await client.post(f"{config.service_urls['service-scraper']}/create_scrape_jobs", timeout=700)
     if response.status_code != 200 and raise_on_failure: