Skip to content

Commit b3f0254

Browse files
committed
Refactor: use _log_signal in _trace_after_publish for consistency
1 parent 9e7db74 commit b3f0254

1 file changed

Lines changed: 1 addition & 5 deletions

File tree

  • instrumentation/opentelemetry-instrumentation-celery/src/opentelemetry/instrumentation/celery

instrumentation/opentelemetry-instrumentation-celery/src/opentelemetry/instrumentation/celery/__init__.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -611,11 +611,7 @@ def _trace_after_publish(*args: object, **kwargs: object) -> None:
611611
task = utils.retrieve_task_from_sender(kwargs)
612612
task_id = utils.retrieve_task_id_from_message(kwargs)
613613
task_name = task.name if task is not None else None
614-
logger.debug(
615-
"after_task_publish signal received task_id=%s task_name=%s",
616-
task_id,
617-
task_name,
618-
)
614+
_log_signal("after_task_publish", task_id, task_name, None)
619615

620616
if task is None or task_id is None:
621617
return

0 commit comments

Comments
 (0)