More logs

Author: tconley1428

temporalio/runtime.py

@@ -142,7 +142,7 @@ def _to_bridge_config(self) -> temporalio.bridge.runtime.LoggingConfig:
 
 
 LoggingConfig.default = LoggingConfig(
-    filter=TelemetryFilter(core_level="WARN", other_level="ERROR")
+    filter=TelemetryFilter(core_level="DEBUG", other_level="ERROR")
 )
 
 _module_start_time = time.time()

temporalio/worker/_activity.py

@@ -183,14 +183,18 @@ def notify_shutdown(self) -> None:
     async def drain_poll_queue(self) -> None:
         while True:
             try:
+                logger.info("Poll activity tasks")
+
                 # Just take all tasks and say we can't handle them
                 task = await self._bridge_worker().poll_activity_task()
                 completion = temporalio.bridge.proto.ActivityTaskCompletion(  # type: ignore[reportAttributeAccessIssue]
                     task_token=task.task_token
                 )
                 completion.result.failed.failure.message = "Worker shutting down"
+                logger.info("Complete activity task")
                 await self._bridge_worker().complete_activity_task(completion)
             except temporalio.bridge.worker.PollShutdownError:  # type: ignore[reportPrivateLocalImportUsage]
+                logger.info("Return from drain")
                 return
 
     # Only call this after run()/drain_poll_queue() have returned. This will not

temporalio/worker/_worker.py

@@ -760,6 +760,7 @@ async def raise_on_shutdown():
         # If any worker task had an exception, replace that task with a queue drain
         for worker, task in tasks.items():
             if worker and task.done() and task.exception():
+                logger.info("Adding a drain task")
                 tasks[worker] = asyncio.create_task(worker.drain_poll_queue())
 
         logger.info("Task drain done")