Oh my word 🙈 Yes, I just saw this just and came back to reply on here. Thank you!

@<1654294828365647872:profile|GorgeousShrimp11> Any change your queue is actually named megan-testing and not megan_testing ?

Error when executing schedule with a pipeline task ID defined:

Launching job: ScheduleJob(name='Simple Pipeline Schedule Run Test', base_task_id='4cf5b603e3ae4593a8c2dd6c34190c6d', base_function=None, queue='megan_testing', target_project=None, single_instance=False, task_parameters={}, task_overrides={}, clone_task=True, _executed_instances=None, execution_limit_hours=None, recurring=True, starting_time=datetime.datetime(1970, 1, 1, 0, 0), minute=2, hour=None, day=None, weekdays=['monday', 'tuesday', 'wednesday', 'thursday', 'friday'], month=None, year=None, _next_run=datetime.datetime(1970, 1, 5, 0, 2), _execution_timeout=None, _last_executed=None, _schedule_counter=0)
Scheduling Job Simple Pipeline Schedule Run Test, Task 3997a7c1de6e446e9ac0d8a87aec3db8 on queue megan_testing.
2024-01-25 09:38:02,317 - clearml.automation.job - WARNING - Error enqueuing Task <clearml.task.Task object at 0x7f6c6f065600> to megan_testing: Could not find queue named "megan_testing"

I have an agent running and assigned to the queue megan-testing :

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')