def get_active_jobs(): batch_job_service = client.GetService('BatchJobService', version='v201809') selector = { 'fields': ['Id', 'Status'], 'predicates': { 'field': 'Status', 'operator': 'IN', 'values': ['ACTIVE', 'AWAITING_FILE'] } } return batch_job_service.get(selector)