Log task processing in sync executor

tasktiger/executor.py

@@ -417,6 +417,8 @@ def execute(
         locks: Collection[Lock],
         queue_lock: Optional[Semaphore],
     ) -> bool:
+        assert tasks
+
         # Run heartbeat thread.
         all_task_ids = {task.id for task in tasks}
         stop_event = threading.Event()
@@ -433,6 +435,15 @@ def execute(
         )
         heartbeat_thread.start()
 
+        serialized_task_func = tasks[0].serialized_func
+        for task in tasks:
+            log.info(
+                "processing",
+                func=serialized_task_func,
+                task_id=task.id,
+                params={"args": task.args, "kwargs": task.kwargs},
+            )
+
         # Run the tasks.
         try:
             result = self.execute_tasks(tasks, log)