def METHOD_NAME():
    if not hasattr(local_data, "scheduler_commands"):
        local_data.scheduler_commands = scheduler_commands_factory(RemoteCommandExecutor(cluster))
    local_data.scheduler_commands.submit_command(
        "sleep {0}; mkdir -p /shared/job-results; mktemp /shared/job-results/job.XXXXXXXX".format(
            benchmark_params["job_duration"]
        ),
        slots=1,
        after_ok=job_id,
    )