| Safe Haskell | None |
|---|---|
| Language | GHC2024 |
Napkin.Spec.Graph.RunGraph
Synopsis
- addNode :: forall (m :: Type -> Type) b. Monad m => TaskId -> Executable b -> (Task (Executable b) -> Task (Executable b)) -> StateT (TasksDAG Full b) m TaskId
- createYAMLTask :: forall b (m :: Type -> Type). (Monad m, MonadError (NonEmpty ValidationError) m) => SpecTableMap b -> SpecTableName -> ProgramAndHooksDependenciesAndQueries b -> StateT (TasksDAG Full b) m ()
- createYAMLTasksGraphRaw :: (Monad m, MonadIO m, TableSpecsAsDependencyGraph b) => ApplyQueryTransformers -> RuntimeEnv -> [RunTableSelector] -> RawInterpretedSpec b -> m (Either (NonEmpty ValidationError) (SpecDepsAndQueries b, TasksDAG Full b))
- createYAMLTasksGraph :: (Monad m, MonadError (NonEmpty ValidationError) m) => [RunTableSelector] -> ValidatedInterpretedSpec b -> m (Set Artifact, TasksDAG Full b)
- createYAMLTasksGraphTransformers :: RawInterpretedSpec b -> [RunTableSelector] -> SpecDepsAndQueries b -> Either (NonEmpty ValidationError) (Set Artifact, TasksDAG Full b)
- applyTableSelectors :: ForcedTaskIdMap -> TasksDAG Full b -> TasksDAG Full b
- applyExecutionPlan :: TasksDAG Table b -> TasksDAG Full b -> TasksDAG Full b
- whoProducesWhat :: forall (m :: Type -> Type) b. (Monad m, MonadError (NonEmpty ValidationError) m) => StateT (TasksDAG Full b) m (Map Artifact TaskId)
- addDummyNodesForUnmanagedArtifacts :: forall (m :: Type -> Type) b. Monad m => StateT (TasksDAG Full b) m (Set Artifact)
- connectInputsAndOutputs :: forall (m :: Type -> Type) b. (Monad m, MonadError (NonEmpty ValidationError) m) => StateT (TasksDAG Full b) m ()
- addGlobalHooks :: forall b (m :: Type -> Type). (Monad m, MonadError (NonEmpty ValidationError) m) => GlobalHooks b -> [(Text, DryRunResult b)] -> StateT (TasksDAG Full b) m ()
- entryId :: Text -> TaskId
- exitId :: Text -> TaskId
- createActionId :: Text -> TaskId
- preHookId :: Text -> Int -> TaskId
- postHookId :: Text -> Int -> TaskId
- globalHookId :: Text -> TaskId
- unmanagedId :: Text -> TaskId
- checkCycles :: forall (m :: Type -> Type) b. (Monad m, MonadError (NonEmpty ValidationError) m) => StateT (TasksDAG Full b) m ()
- findCycles :: TasksDAGGraph Full b -> [[Task (Executable b)]]
Documentation
addNode :: forall (m :: Type -> Type) b. Monad m => TaskId -> Executable b -> (Task (Executable b) -> Task (Executable b)) -> StateT (TasksDAG Full b) m TaskId #
createYAMLTask :: forall b (m :: Type -> Type). (Monad m, MonadError (NonEmpty ValidationError) m) => SpecTableMap b -> SpecTableName -> ProgramAndHooksDependenciesAndQueries b -> StateT (TasksDAG Full b) m () #
createYAMLTasksGraphRaw :: (Monad m, MonadIO m, TableSpecsAsDependencyGraph b) => ApplyQueryTransformers -> RuntimeEnv -> [RunTableSelector] -> RawInterpretedSpec b -> m (Either (NonEmpty ValidationError) (SpecDepsAndQueries b, TasksDAG Full b)) #
createYAMLTasksGraph :: (Monad m, MonadError (NonEmpty ValidationError) m) => [RunTableSelector] -> ValidatedInterpretedSpec b -> m (Set Artifact, TasksDAG Full b) #
createYAMLTasksGraphTransformers :: RawInterpretedSpec b -> [RunTableSelector] -> SpecDepsAndQueries b -> Either (NonEmpty ValidationError) (Set Artifact, TasksDAG Full b) #
applyTableSelectors :: ForcedTaskIdMap -> TasksDAG Full b -> TasksDAG Full b #
applyExecutionPlan :: TasksDAG Table b -> TasksDAG Full b -> TasksDAG Full b #
Given table task's graph applies update strategies to the whole table subgraph
whoProducesWhat :: forall (m :: Type -> Type) b. (Monad m, MonadError (NonEmpty ValidationError) m) => StateT (TasksDAG Full b) m (Map Artifact TaskId) #
addDummyNodesForUnmanagedArtifacts :: forall (m :: Type -> Type) b. Monad m => StateT (TasksDAG Full b) m (Set Artifact) #
connectInputsAndOutputs :: forall (m :: Type -> Type) b. (Monad m, MonadError (NonEmpty ValidationError) m) => StateT (TasksDAG Full b) m () #
addGlobalHooks :: forall b (m :: Type -> Type). (Monad m, MonadError (NonEmpty ValidationError) m) => GlobalHooks b -> [(Text, DryRunResult b)] -> StateT (TasksDAG Full b) m () #
createActionId :: Text -> TaskId #
postHookId :: Text -> Int -> TaskId #
globalHookId :: Text -> TaskId #
unmanagedId :: Text -> TaskId #
checkCycles :: forall (m :: Type -> Type) b. (Monad m, MonadError (NonEmpty ValidationError) m) => StateT (TasksDAG Full b) m () #
findCycles :: TasksDAGGraph Full b -> [[Task (Executable b)]] #