Safe Haskell	Safe-Inferred
Language	GHC2021

Napkin.Spec.Graph.RunGraph

Synopsis

addNode :: forall m b. Monad m => TaskId -> Executable b -> (Task (Executable b) -> Task (Executable b)) -> StateT (TasksDAG Full b) m TaskId
createYAMLTaskGraph :: forall b m. (MonadIO m, MustacheBackend b, RunBackendEffect b, DumpBackendRequirements b) => SpecTableName -> ProgramDependenciesAndQueries b -> SpecTableMap b -> StateT (TasksDAG Full b) m ()
createYAMLTaskGraphs :: forall b m. (MonadIO m, MustacheBackend b, RunBackendEffect b, DumpBackendRequirements b) => ApplyQueryTransformers -> RuntimeEnv -> RawInterpretedSpec b -> [RunTableSelector] -> m (Either (NonEmpty ValidationError) (Set Artifact, TasksDAG Full b))
createYAMLTaskGraphsTaskGroup :: forall b. (MustacheBackend b, RunBackendEffect b, DumpBackendRequirements b) => TaskGroup -> ApplyQueryTransformers -> RuntimeEnv -> RawInterpretedSpec b -> [RunTableSelector] -> IO (Either (NonEmpty ValidationError) ([(SpecTableName, ProgramDependenciesAndQueries b)], Set Artifact, TasksDAG Full b))
createYAMLTaskGraphs' :: forall b m. (MonadIO m, MustacheBackend b, RunBackendEffect b, DumpBackendRequirements b) => ApplyQueryTransformers -> RawInterpretedSpec b -> [RunTableSelector] -> [(SpecTableName, ProgramDependenciesAndQueries b)] -> ExceptT (NonEmpty ValidationError) m (Set Artifact, TasksDAG Full b)
applyExecutionPlan :: forall b. TasksDAG Table b -> TasksDAG Full b -> TasksDAG Full b
whoProducesWhat :: TasksDAG kind b -> Map Artifact TaskId
addDummyNodesForUnmanagedArtifacts :: Monad m => StateT (TasksDAG Full b) m (Set Artifact)
connectInputsAndOutputs :: (Monad m, MonadError (NonEmpty ValidationError) m) => StateT (TasksDAG Full b) m (Map Artifact TaskId)
addGlobalHooks :: (Monad m, MonadError (NonEmpty ValidationError) m) => (SpecTableName -> Ref Table) -> Map Artifact TaskId -> GlobalHooks b -> StateT (TasksDAG Full b) m ()
createActionId :: Text -> TaskId
preHookId :: Text -> Int -> TaskId
postHookId :: Text -> Int -> TaskId
globalHookId :: Text -> Int -> TaskId
checkDuplicateOutputs :: (Monad m, MonadError (NonEmpty ValidationError) m) => [Artifact] -> StateT (TasksDAG Full b) m ()
checkCycles :: (Monad m, MonadError (NonEmpty ValidationError) m) => StateT (TasksDAG Full b) m ()
findCycles :: TasksDAGGraph Full b -> [[Task (Executable b)]]

Documentation

addNode :: forall m b. Monad m => TaskId -> Executable b -> (Task (Executable b) -> Task (Executable b)) -> StateT (TasksDAG Full b) m TaskId #

createYAMLTaskGraph :: forall b m. (MonadIO m, MustacheBackend b, RunBackendEffect b, DumpBackendRequirements b) => SpecTableName -> ProgramDependenciesAndQueries b -> SpecTableMap b -> StateT (TasksDAG Full b) m () #

createYAMLTaskGraphs :: forall b m. (MonadIO m, MustacheBackend b, RunBackendEffect b, DumpBackendRequirements b) => ApplyQueryTransformers -> RuntimeEnv -> RawInterpretedSpec b -> [RunTableSelector] -> m (Either (NonEmpty ValidationError) (Set Artifact, TasksDAG Full b)) #

createYAMLTaskGraphsTaskGroup :: forall b. (MustacheBackend b, RunBackendEffect b, DumpBackendRequirements b) => TaskGroup -> ApplyQueryTransformers -> RuntimeEnv -> RawInterpretedSpec b -> [RunTableSelector] -> IO (Either (NonEmpty ValidationError) ([(SpecTableName, ProgramDependenciesAndQueries b)], Set Artifact, TasksDAG Full b)) #

createYAMLTaskGraphs' :: forall b m. (MonadIO m, MustacheBackend b, RunBackendEffect b, DumpBackendRequirements b) => ApplyQueryTransformers -> RawInterpretedSpec b -> [RunTableSelector] -> [(SpecTableName, ProgramDependenciesAndQueries b)] -> ExceptT (NonEmpty ValidationError) m (Set Artifact, TasksDAG Full b) #

applyExecutionPlan :: forall b. TasksDAG Table b -> TasksDAG Full b -> TasksDAG Full b #

Given table task's graph applies update strategies to the whole tasks' graph

whoProducesWhat :: TasksDAG kind b -> Map Artifact TaskId #

addDummyNodesForUnmanagedArtifacts :: Monad m => StateT (TasksDAG Full b) m (Set Artifact) #

connectInputsAndOutputs :: (Monad m, MonadError (NonEmpty ValidationError) m) => StateT (TasksDAG Full b) m (Map Artifact TaskId) #

addGlobalHooks :: (Monad m, MonadError (NonEmpty ValidationError) m) => (SpecTableName -> Ref Table) -> Map Artifact TaskId -> GlobalHooks b -> StateT (TasksDAG Full b) m () #

createActionId :: Text -> TaskId #

preHookId :: Text -> Int -> TaskId #

postHookId :: Text -> Int -> TaskId #

globalHookId :: Text -> Int -> TaskId #

checkDuplicateOutputs :: (Monad m, MonadError (NonEmpty ValidationError) m) => [Artifact] -> StateT (TasksDAG Full b) m () #

checkCycles :: (Monad m, MonadError (NonEmpty ValidationError) m) => StateT (TasksDAG Full b) m () #

findCycles :: TasksDAGGraph Full b -> [[Task (Executable b)]] #