def METHOD_NAME(self):
    p = make_new_pipeline(f"monitor_job{random_str()}")
    p1 = p.readFrom(source_name).writeTo(sink_name)
    p1.start()
    assert wait_scheduling(p1, except_status=('running',))
    p1.monitor(t=2)