Temporarily disable passing worker labels to flow run (#16339)

PrefectHQ · Dec 11, 2024 · 6bfce9e · 6bfce9e
1 parent 686d4c3
commit 6bfce9e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/prefect/workers/base.py b/src/prefect/workers/base.py
@@ -989,7 +989,6 @@ async def _submit_run_and_capture_errors(
         try:
             configuration = await self._get_configuration(flow_run)
             submitted_event = self._emit_flow_run_submitted_event(configuration)
-            await self._give_worker_labels_to_flow_run(flow_run.id)
             result = await self.run(
                 flow_run=flow_run,
                 task_status=task_status,

diff --git a/tests/workers/test_base_worker.py b/tests/workers/test_base_worker.py
@@ -2083,6 +2083,7 @@ async def _worker_metadata(self) -> WorkerMetadata:
             assert worker._worker_metadata_sent
 
 
+@pytest.mark.skip(reason="Passing worker labels to flow run is temporarily disabled")
 async def test_worker_gives_labels_to_flow_runs_when_using_cloud_api(
     prefect_client: PrefectClient, worker_deployment_wq1, work_pool
 ):
@@ -2118,6 +2119,7 @@ def create_run_with_deployment(state):
     )
 
 
+@pytest.mark.skip(reason="Passing worker labels to flow run is temporarily disabled")
 async def test_worker_does_not_give_labels_to_flow_runs_when_not_using_cloud_api(
     prefect_client: PrefectClient, worker_deployment_wq1, work_pool
 ):