code: def workflow_incomplete(self):
          
  
          try:
              for pipe in self._workflow:
                  with pipe.lock:
                      if pipe.completed:
                          pass
                      else:
                          return True
              return False
  
          except Exception, ex:
              self._logger.exception(
                  'Could not check if workflow is incomplete, error:%s' % ex)
              raise
docs: **Purpose**: Method to check if the workflow execution is incomplete.