get_schedule_k1_recent_job_stats.py

get_schedule_k1_recent_job_stats.py

from fund_admin.audited_celery.models import CeleryTask

tasks = CeleryTask.objects.filter(name__contains='create_schedule_k1s_for_fund_partners').order_by('-created_at')[:10]

for task in tasks:
    created_at_str = task.created_at.strftime('%m/%d at %H:%M')
    job_status = task.state
    print(f'Started: {created_at_str}')
    print(f'Status: {job_status}')
    if job_status == 'SUCCESS':
        duration = task.post_run - task.pre_run
        print(f'Duration: {duration}')
    else:
        print(f'Exception: {task.exception}')
    print('-------------------')