Schedule testing code:

# Schedule for running the pipeline daily

from clearml import Task
from clearml.automation import TaskScheduler


def simple_function():
    print('This code is executed in a background thread, '
          'on the same machine as the TaskScheduler process')
    # add some logic here
    print('done')

if __name__ == "__main__":

    scheduler = TaskScheduler(force_create_task_name='megan-test-remote-pipeline')

    scheduler.add_task(
        name='Simple Pipeline Schedule Run Test',
        schedule_function=simple_function,
        # schedule_task_id='4cf5b603e3ae4593a8c2dd6c34190c6d',
        queue='megan_testing',
        minute=2,
        weekdays=['monday', 'tuesday', 'wednesday', 'thursday', 'friday'],
        recurring=True,
        execute_immediately=True
    )

    scheduler.start_remotely()
    # scheduler.start()

    print('This line will run remotely')