14759e1065e307c7760299670da30f64ffdbf783,src/python/pants/engine/engine.py,LocalMultiprocessEngine,_submit_until,#LocalMultiprocessEngine#Any#Any#Any#,450

Before Change

        if step.step_id in in_flight:
          raise InFlightException("{} is already in_flight!".format(step))

        step = self._storage.key_for_request(step)
        result = self._maybe_cache_get(step)
        if result is not None:
          // Skip in_flight on cache hit.
          promise.success(result)
        else:

After Change

      result = self._cache.get_for_key(runnable_key) if is_cacheable else None
      if result is not None:
        // Skip in_flight on cache hit.
        completed.append((step, result))
      else:
        step_id = id(step)
        in_flight[step_id] = step

Instances