Interface IComputationTaskManager

All Known Implementing Classes:
DerivedDataManager

public interface IComputationTaskManager
Component that is responsible for providing workers with tasks and tracking task statuses.
  • Method Details

    • getAsyncPipelineStatus

      PipelineStatus getAsyncPipelineStatus()
      Gets the current pipeline status of the async. pipeline.
      Returns:
      The status of the pipeline.
    • getSegmentName

      String getSegmentName(String segmentId)
      Gets the human-readable segment name for the given pipeline segment.
      Parameters:
      segmentId - The identifier of the target segment.
      Returns:
      The the name of the segment.
    • isLongRunningSegment

      boolean isLongRunningSegment(String segmentId)
      Checks if the given async. DD segment is a long-running one.
      Parameters:
      segmentId - The target segment identifier.
      Returns:
      True if the segment is long-running one; false otherwise.
    • notifyContextsAreScheduled

      void notifyContextsAreScheduled(boolean notifyListeners)
      Notifies the task manager about finishing of the computation or new DD part scheduling.
      Parameters:
      notifyListeners - Notify task listeners.
    • renderStatusText

      String renderStatusText(String segmentId)
      Renders human-readable status of the given async. DD pipeline segment.
      Parameters:
      segmentId - The identifier of the taget segment.
      Returns:
      The rendered status of the pipeline segment.