code: def check_concurrency(self) -> bool:
          
          if not self.operation.concurrency:  # No concurrency set
              return True
  
          ops_count = self.operation.runs.filter(
              status__status__in=self.STATUSES.RUNNING_STATUS).count()
          return ops_count < self.operation.concurrency
docs: Checks the concurrency of the operation run.
  
          Checks the concurrency of the operation run
          to validate if we can start a new operation run.
  
          Returns:
              boolean: Whether to start a new operation run or not.