Add debug log for global concurrency limit wait (#16077)

Co-authored-by: nate nowack <[email protected]>
PrefectHQ · Nov 21, 2024 · d296aa2 · d296aa2
1 parent 59455b6
commit d296aa2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/prefect/concurrency/services.py b/src/prefect/concurrency/services.py
@@ -83,6 +83,9 @@ async def acquire_slots(
                         if max_retries is not None and max_retries <= 0:
                             raise exc
                         retry_after = float(exc.response.headers["Retry-After"])
+                        logger.debug(
+                            f"Unable to acquire concurrency slot. Retrying in {retry_after} second(s)."
+                        )
                         await asyncio.sleep(retry_after)
                         if max_retries is not None:
                             max_retries -= 1