@op
def op_1(context: OpExecutionContext):
    print('external API call')


@job
def job_1():
    op_1()


@schedule(
    name='scheduled_job_1',
    job=job_1,
    cron_schedule='*/15 * * * *',  # Every 15 minutes
    default_status=DefaultScheduleStatus.RUNNING,
)
def scheduled_job_1(context: ScheduleEvaluationContext) -> RunRequest:
    return RunRequest(run_key=None, run_config={'ops': {'op_1': {}}})


@op
def op_2(context: OpExecutionContext):
    print('external API call')


@job
def job_2():
    op_2()


@schedule(
    name='scheduled_job_2',
    job=job_2,
    cron_schedule='15 * * * *',  # At 15 minutes past the hour
    default_status=DefaultScheduleStatus.RUNNING,
)
def scheduled_job_2(context: ScheduleEvaluationContext) -> RunRequest:
    return RunRequest(run_key=None, run_config={'ops': {'op_2': {}}})


@op
def op_3(context: OpExecutionContext):
    print('external API call')


@job
def job_3():
    op_3()


@schedule(
    name='scheduled_job_3',
    job=job_3,
    cron_schedule='15 * * * *',  # At 15 minutes past the hour
    default_status=DefaultScheduleStatus.RUNNING,
)
def scheduled_job_3(context: ScheduleEvaluationContext) -> RunRequest:
    # TODO: Wait for job_1 at the 15 minute after the full hour to be finished first <--
    # TODO: Wait for job_2 at the 15 minute after the full hour to be finished first <--
    # TODO: Only then run this schedule <--
    return RunRequest(run_key=None, run_config={'ops': {'op_3': {}}})

@repository
def repo():
    return [scheduled_job_1, scheduled_job_2, scheduled_job_3]