Merge pull request #55 from TogetherCrew/feat/mediawiki-workflows

fix: wrong args for execute child workflow!

Author: amindadgar

hivemind_etl/mediawiki/workflows.py

@@ -129,15 +129,15 @@ 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
                     transformed_data_key = await workflow.execute_child_workflow(
                         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(