def METHOD_NAME(self):
    p = Pipeline(name=f"filter_column_sync_{random_str()}")
    p.dag.jobType = JobType.sync
    p1 = p.readFrom(f"{source_name}.test")
    p2 = p1.filterColumn(["id", "name"]).writeTo(f"{sink_name}.test")
    p2.start()
    assert wait_scheduling(p2, except_status=('running', 'wait_run'))
    assert stop(p2)