def METHOD_NAME(task_runner):
    reset_watermarks()
    with assume_test_silo_mode(SiloMode.CONTROL):
        results, _ = setup_deletable_objects(10)
        with BurstTaskRunner() as burst:
            schedule_hybrid_cloud_foreign_key_jobs_control()
        burst()
        # Do not process
        assert results.exists()