| Safe Haskell | None |
|---|---|
| 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
Constructors
| History | |
Fields | |
Instances
| Generic History # | |||||
Defined in Napkin.Spec.Persist Associated Types
| |||||
| Default History # | |||||
Defined in Napkin.Spec.Persist | |||||
| type Rep History # | |||||
Defined in Napkin.Spec.Persist type Rep History = D1 ('MetaData "History" "Napkin.Spec.Persist" "napkin-1.0.0-5YkWAC9Wc776PT0LDghaFb" 'False) (C1 ('MetaCons "History" 'PrefixI 'True) (S1 ('MetaSel ('Just "lastCompletedRun") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SpecState) :*: S1 ('MetaSel ('Just "lastRun") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SpecState))) | |||||
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] #