async def METHOD_NAME(
    rabbitmq_client: RabbitMQClient,
    *,
    user_id: UserID,
    simcore_user_agent: str,
    task: CompTaskAtDB,
) -> None:
    message = InstrumentationRabbitMessage.construct(
        metrics="service_started",
        user_id=user_id,
        project_id=task.project_id,
        node_id=task.node_id,
        service_uuid=task.node_id,
        service_type=task.node_class.value,
        service_key=task.image.name,
        service_tag=task.image.tag,
        simcore_user_agent=simcore_user_agent,
    )
    await rabbitmq_client.publish(message.channel_name, message)