| Safe Haskell | None |
|---|---|
| Language | GHC2021 |
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
- createYAMLTaskGraph :: forall b (m :: Type -> Type). (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) ([(SpecTableName, ProgramDependenciesAndQueries b)], 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 {k} (kind :: k) b. TasksDAG kind b -> 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 (Map Artifact TaskId)
- addGlobalHooks :: forall (m :: Type -> Type) b. (Monad m, MonadError (NonEmpty ValidationError) m) => (SpecTableName -> Ref Table) -> Map Artifact TaskId -> GlobalHooks 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 -> Int -> TaskId
- unmanagedId :: Text -> TaskId
- checkDuplicateOutputs :: forall (m :: Type -> Type) b. (Monad m, MonadError (NonEmpty ValidationError) m) => [Artifact] -> StateT (TasksDAG Full b) m ()
- 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 #
createYAMLTaskGraph :: forall b (m :: Type -> Type). (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) ([(SpecTableName, ProgramDependenciesAndQueries b)], 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
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 (Map Artifact TaskId) #
addGlobalHooks :: forall (m :: Type -> Type) b. (Monad m, MonadError (NonEmpty ValidationError) m) => (SpecTableName -> Ref Table) -> Map Artifact TaskId -> GlobalHooks b -> StateT (TasksDAG Full b) m () #
createActionId :: Text -> TaskId #
postHookId :: Text -> Int -> TaskId #
globalHookId :: Text -> Int -> TaskId #
unmanagedId :: Text -> TaskId #
checkDuplicateOutputs :: forall (m :: Type -> Type) b. (Monad m, MonadError (NonEmpty ValidationError) m) => [Artifact] -> StateT (TasksDAG Full b) m () #
checkCycles :: forall (m :: Type -> Type) b. (Monad m, MonadError (NonEmpty ValidationError) m) => StateT (TasksDAG Full b) m () #
findCycles :: TasksDAGGraph Full b -> [[Task (Executable b)]] #