Function emit

tests/test_task_notification.py:238–243

(status: str)

    barrier = threading.Barrier(2)

    def emit(status: str) -> None:
        barrier.wait()  # both threads enter at the same instant
        enqueue_agent_notification(
            task_id=state.id, description=state.description,
            status=status, output_file=state.output_file, registry=reg,
        )

    t1 = threading.Thread(target=emit, args=("completed",))
    t2 = threading.Thread(target=emit, args=("killed",))