From 58478b39e374a2f9689264cdf7c9887756822d95 Mon Sep 17 00:00:00 2001 From: gitea_admin Date: Wed, 15 Jul 2026 20:34:04 +0000 Subject: [PATCH] Update laborious/worker/worker.py --- laborious/worker/worker.py | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/laborious/worker/worker.py b/laborious/worker/worker.py index edd7e2f..f284a8c 100644 --- a/laborious/worker/worker.py +++ b/laborious/worker/worker.py @@ -141,10 +141,19 @@ async def main(): metrics_controller=metrics_controller, ) + if runtime == 'legacy': + to_install_runtime = 'single' + else: + to_install_runtime = runtime + try: - await plugin_store.install_runtime(runtime_name=runtime, metadata=metadata_runtime) + await plugin_store.install_runtime( + runtime_name=to_install_runtime, metadata=metadata_runtime + ) except Exception as exc: - logger.custom_critical(f'Failed to install runtime {runtime}: {exc}', metadata_runtime) + logger.custom_critical( + f'Failed to install runtime {to_install_runtime}: {exc}', metadata_runtime + ) metrics.APP_UP.labels(pod_id=POD_ID).set(0) sys.exit(1) @@ -207,6 +216,7 @@ async def main(): activities.export_data_to_postgres, ], logger=logger, + runtime='core', ), prepare_worker( temporal_client=temporal_client, @@ -219,6 +229,7 @@ async def main(): activities.export_data_to_postgres, ], logger=logger, + runtime='core', ), prepare_worker( temporal_client=temporal_client,