reana_workflow_controller/tasks.py
def _update_job_progress(workflow_uuid, msg):
    """Update job progress for jobs in received message."""
    workflow = Session.query(Workflow).filter_by(
        id_=workflow_uuid).one_or_none()
    for status in PROGRESS_STATUSES:
        if status in msg['progress']:
            status_progress = msg['progress'][status]
            for job_id in status_progress['job_ids']:
                try:
                    uuid.UUID(job_id)
                except Exception:
                    continue
                Session.query(Job).filter_by(id_=job_id).\
                    update({'workflow_uuid': workflow_uuid,
                            'status': status})
Update job progress for jobs in received message.
Update job progress for jobs in received message.
Update job progress for jobs in received message .
def _update_job_progress(workflow_uuid, msg):
    workflow = Session.query(Workflow).filter_by(
        id_=workflow_uuid).one_or_none()
    for status in PROGRESS_STATUSES:
        if status in msg['progress']:
            status_progress = msg['progress'][status]
            for job_id in status_progress['job_ids']:
                try:
                    uuid.UUID(job_id)
                except Exception:
                    continue
                Session.query(Job).filter_by(id_=job_id).\
                    update({'workflow_uuid': workflow_uuid,
                            'status': status})
def _update_job_progress ( workflow_uuid , msg ) : workflow = Session . query ( Workflow ) . filter_by ( id_ = workflow_uuid ) . one_or_none ( ) for status in PROGRESS_STATUSES : if status in msg [ 'progress' ] : status_progress = msg [ 'progress' ] [ status ] for job_id in status_progress [ 'job_ids' ] : try : uuid . UUID ( job_id ) except Exception : continue Session . query ( Job ) . filter_by ( id_ = job_id ) . update ( { 'workflow_uuid' : workflow_uuid , 'status' : status } )
Update job progress for jobs in received message.
Update job progress for jobs in received message .
"""Update job progress for jobs in received message."""
workflow_uuid
msg