aztk/utils/helpers.py
def wait_for_task_to_complete(job_id: str, task_id: str, batch_client):
    """
    Waits for a particular task in a job to complete.
    :param batch_client: The batch client to use.
    :type batch_client: `batchserviceclient.BatchServiceClient`
    :param str job_id: The id of the job to monitor.
    :param str job_id: The id of the task to monitor.
    """
    while True:
        task = batch_client.task.get(job_id=job_id, task_id=task_id)
        if task.state != batch_models.TaskState.completed:
            time.sleep(5)
        else:
            return

    Waits for a particular task in a job to complete.
    :param batch_client: The batch client to use.
    :type batch_client: `batchserviceclient.BatchServiceClient`
    :param str job_id: The id of the job to monitor.
    :param str job_id: The id of the task to monitor.
    
Waits for a particular task in a job to complete.
Waits for a particular task in a job to complete .
def wait_for_task_to_complete(job_id: str, task_id: str, batch_client):
    while True:
        task = batch_client.task.get(job_id=job_id, task_id=task_id)
        if task.state != batch_models.TaskState.completed:
            time.sleep(5)
        else:
            return
def wait_for_task_to_complete ( job_id : str , task_id : str , batch_client ) : while True : task = batch_client . task . get ( job_id = job_id , task_id = task_id ) if task . state != batch_models . TaskState . completed : time . sleep ( 5 ) else : return
Waits for a particular task in a job to complete.
Waits for a particular task in a job to complete .
"""
    Waits for a particular task in a job to complete.
    :param batch_client: The batch client to use.
    :type batch_client: `batchserviceclient.BatchServiceClient`
    :param str job_id: The id of the job to monitor.
    :param str job_id: The id of the task to monitor.
    """
job_id
str
The id of the task to monitor.
The id of the task to monitor .
task_id
str
batch_client
The batch client to use.
The batch client to use .