diff --git a/tasktiger/executor.py b/tasktiger/executor.py index d6cf454..11553bd 100644 --- a/tasktiger/executor.py +++ b/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)