diff --git a/hivemind_etl/mediawiki/workflows.py b/hivemind_etl/mediawiki/workflows.py index ff5bf97..a5d71c4 100644 --- a/hivemind_etl/mediawiki/workflows.py +++ b/hivemind_etl/mediawiki/workflows.py @@ -129,7 +129,7 @@ async def run(self, platform_id: str | None = None) -> None: ExtractMediaWikiWorkflow.run, mediawiki_platform, id=f"mediawiki:extract:{platform['community_id']}", - start_to_close_timeout=timedelta(days=5), + execution_timeout=timedelta(days=6), ) # Transform the extracted data and store in S3 @@ -137,7 +137,7 @@ async def run(self, platform_id: str | None = None) -> None: TransformMediaWikiWorkflow.run, mediawiki_platform, id=f"mediawiki:transform:{platform['community_id']}", - start_to_close_timeout=timedelta(hours=6), + execution_timeout=timedelta(hours=6), ) mediawiki_platform["transformed_data_key"] = transformed_data_key @@ -146,7 +146,7 @@ async def run(self, platform_id: str | None = None) -> None: LoadMediaWikiWorkflow.run, mediawiki_platform, id=f"mediawiki:load:{platform['community_id']}", - start_to_close_timeout=timedelta(hours=3), + execution_timeout=timedelta(days=3), ) logging.info(