code: def complete(self):
          
          if callable(self.task.workflow_complete):
              return self.task.workflow_complete()
          else:
              return super(BaseWorkflowProxy, self).complete()
docs: Custom completion check that invokes the task's *workflow_complete* if it is callable, or
          just does the default completion check otherwise.