def create_job(self, command_handler, job_handle, task, unique, data):
    'Create a new job using our self.job_class'
    current_connection = self.handler_to_connection_map[command_handler]
    return self.job_class(current_connection, job_handle, task, unique, data)
Create a new job using our self.job_class
def create_job(self, command_handler, job_handle, task, unique, data):
    
    current_connection = self.handler_to_connection_map[command_handler]
    return self.job_class(current_connection, job_handle, task, unique, data)