aztk/node_scripts/scheduling/job_submission.py
def schedule_tasks(tasks):
    """
        Handle the request to submit a task
    """
    batch_client = config.batch_client

    for task in tasks:
        # affinitize task to master
        task = affinitize_task_to_master(batch_client, os.environ["AZ_BATCH_POOL_ID"], task)
        # schedule the task
        batch_client.task.add(job_id=os.environ["AZ_BATCH_JOB_ID"], task=task)

        Handle the request to submit a task
    
Handle the request to submit a task
Handle the request to submit a task
def schedule_tasks(tasks):
    batch_client = config.batch_client
    for task in tasks:
        task = affinitize_task_to_master(batch_client, os.environ["AZ_BATCH_POOL_ID"], task)
        batch_client.task.add(job_id=os.environ["AZ_BATCH_JOB_ID"], task=task)
def schedule_tasks ( tasks ) : batch_client = config . batch_client for task in tasks : task = affinitize_task_to_master ( batch_client , os . environ [ "AZ_BATCH_POOL_ID" ] , task ) batch_client . task . add ( job_id = os . environ [ "AZ_BATCH_JOB_ID" ] , task = task )
Handle the request to submit a task
Handle the request to submit a task
"""
        Handle the request to submit a task
    """ # affinitize task to master # schedule the task
tasks