Created by Lucas Correia last modified 2017-03-14

mark_stalled_jobs_as_failed.py

      # :coding: utf-8
# :copyright: Copyright (c) 2017 ftrack
'''Update stalled Jobs and set their status to failed.'''
import datetime
import ftrack_api

session = ftrack_api.Session()

# Query all jobs created prior to yesterday which has not yet been completed.
yesterday = datetime.date.today() - datetime.timedelta(days=1)
jobs = session.query(
    'select id, status from Job '
    'where status in ("queued", "running") and created_at < {0}'.format(yesterday)
)

# Update all the queried jobs, setting the status to failed.
for job in jobs:
    print 'Changing Job ({}) status: {} -> failed'.format(job['id'], job['status'])
    job['status'] = 'failed'

session.commit()

print 'Complete'

    

Comments (3)

HTTPS

SSH

You can clone a snippet to your computer for local editing. Learn more.