From 98592bd40e9457718248345f21a5463bf9eab689 Mon Sep 17 00:00:00 2001 From: Sam Phinizy Date: Mon, 11 Nov 2024 17:06:50 -0500 Subject: [PATCH] Fixes the arguments for the url generation in BaseWorker (#15982) --- src/prefect/workers/base.py | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) diff --git a/src/prefect/workers/base.py b/src/prefect/workers/base.py index 22e6728f0132..8c26e8b9b299 100644 --- a/src/prefect/workers/base.py +++ b/src/prefect/workers/base.py @@ -878,13 +878,18 @@ async def _submit_scheduled_flow_runs( get_current_settings().experiments.worker_logging_to_api_enabled and self.backend_id ): - worker_url = url_for( - "worker", self._work_pool.name, worker_id=self.backend_id - ) + try: + worker_url = url_for( + "worker", + obj_id=self.backend_id, + work_pool_name=self._work_pool_name, + ) - run_logger.info( - f"Running on worker id: {self.backend_id}. See worker logs here: {worker_url}" - ) + run_logger.info( + f"Running on worker id: {self.backend_id}. See worker logs here: {worker_url}" + ) + except ValueError as ve: + run_logger.warning(f"Failed to generate worker URL: {ve}") self._submitting_flow_run_ids.add(flow_run.id) self._runs_task_group.start_soon(