def get_current_job(connection=None):
 job_id = _job_stack.top
 if (job_id is None):
  return None
 return Job.fetch(job_id, connection=connection)

def get_current_job ( connection = None ) : job_id = _job_stack . top if ( job_id is None ) : return None return Job . fetch ( job_id , connection = connection )
returns the job instance that is currently being executed .