| Safe Haskell | Safe-Inferred |
|---|---|
| Language | GHC2021 |
Napkin.Spec.Persist
Synopsis
- data History = History {}
- loadSpecState :: MonadIO m => MetadataBeamConnection -> AppName -> m SpecState
- loadCompletedSpecState :: MonadIO m => MetadataBeamConnection -> AppName -> m SpecState
- loadHistory :: MonadIO m => MetadataBeamConnection -> AppName -> m History
- recordedRunDAG :: (HasBackendQueryStats bk, Typeable bk, ToDbBackend bk) => Task (Executable bk) -> MetadataBeamConnection -> AppName -> Pipeline -> SpecRunId -> SimpleLogPayload -> DepChain -> Combo bk (TaskResult bk) -> Combo bk (Either SomeException (NominalDiffTime, TaskResult bk))
- recordedRun :: (HasBackendQueryStats bk, Typeable bk, ToDbBackend bk) => MetadataBeamConnection -> AppName -> Pipeline -> SpecRunId -> SpecTableName -> Specs bk -> DepChain -> Combo bk (a, CreateQueryStats bk, Maybe (HookQueryStats bk)) -> Combo bk (Either SomeException (a, (NominalDiffTime, CreateQueryStats bk, Maybe (HookQueryStats bk))))
- expectedRuntimeForGraph :: MonadIO m => MetadataBeamConnection -> SpecDepGraph -> Set SpecTableName -> m (Either Text EtaType)
- filterByNodeLabel :: (SpecTableName -> Bool) -> SpecDepGraph -> SpecDepGraph
- checkRunOrder :: (MonadIO m, HasBackendQueryStats bk, Typeable bk, ToDbBackend bk) => MetadataBeamConnection -> SpecRunId -> TasksDAG Exec bk -> m [Text]
Documentation
loadSpecState :: MonadIO m => MetadataBeamConnection -> AppName -> m SpecState #
loadCompletedSpecState :: MonadIO m => MetadataBeamConnection -> AppName -> m SpecState #
loadHistory :: MonadIO m => MetadataBeamConnection -> AppName -> m History #
recordedRunDAG :: (HasBackendQueryStats bk, Typeable bk, ToDbBackend bk) => Task (Executable bk) -> MetadataBeamConnection -> AppName -> Pipeline -> SpecRunId -> SimpleLogPayload -> DepChain -> Combo bk (TaskResult bk) -> Combo bk (Either SomeException (NominalDiffTime, TaskResult bk)) #
Do a run, recording the instance in the database. Return the recorded instance along with the run results.
recordedRun :: (HasBackendQueryStats bk, Typeable bk, ToDbBackend bk) => MetadataBeamConnection -> AppName -> Pipeline -> SpecRunId -> SpecTableName -> Specs bk -> DepChain -> Combo bk (a, CreateQueryStats bk, Maybe (HookQueryStats bk)) -> Combo bk (Either SomeException (a, (NominalDiffTime, CreateQueryStats bk, Maybe (HookQueryStats bk)))) #
Do a run, recording the instance in the database. Return the recorded instance along with the run results.
expectedRuntimeForGraph :: MonadIO m => MetadataBeamConnection -> SpecDepGraph -> Set SpecTableName -> m (Either Text EtaType) #
filterByNodeLabel :: (SpecTableName -> Bool) -> SpecDepGraph -> SpecDepGraph #
checkRunOrder :: (MonadIO m, HasBackendQueryStats bk, Typeable bk, ToDbBackend bk) => MetadataBeamConnection -> SpecRunId -> TasksDAG Exec bk -> m [Text] #