napkin-runtime
Safe HaskellNone
LanguageGHC2024

Napkin.Run.Metadata

Synopsis

Documentation

type TableLastRuns = SpecTableName -> Maybe LastRunInfos #

data LastRunInfos #

Constructors

LastRunInfos 

Fields

Instances

Instances details
FromJSON LastRunInfos # 
Instance details

Defined in Napkin.Run.Metadata

Methods

parseJSON :: Value -> Parser LastRunInfos #

parseJSONList :: Value -> Parser [LastRunInfos] #

omittedField :: Maybe LastRunInfos #

ToJSON LastRunInfos # 
Instance details

Defined in Napkin.Run.Metadata

Methods

toJSON :: LastRunInfos -> Value #

toEncoding :: LastRunInfos -> Encoding #

toJSONList :: [LastRunInfos] -> Value #

toEncodingList :: [LastRunInfos] -> Encoding #

omitField :: LastRunInfos -> Bool #

Generic LastRunInfos # 
Instance details

Defined in Napkin.Run.Metadata

Associated Types

type Rep LastRunInfos 
Instance details

Defined in Napkin.Run.Metadata

type Rep LastRunInfos = D1 ('MetaData "LastRunInfos" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'False) (C1 ('MetaCons "LastRunInfos" 'PrefixI 'True) (S1 ('MetaSel ('Just "lastRun") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe LastRunInfo)) :*: S1 ('MetaSel ('Just "lastSuccessfulRun") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe LastSuccessfulRunInfo))))

Methods

from :: LastRunInfos -> Rep LastRunInfos x #

to :: Rep LastRunInfos x -> LastRunInfos #

Show LastRunInfos # 
Instance details

Defined in Napkin.Run.Metadata

Methods

showsPrec :: Int -> LastRunInfos -> ShowS #

show :: LastRunInfos -> String #

showList :: [LastRunInfos] -> ShowS #

type Rep LastRunInfos # 
Instance details

Defined in Napkin.Run.Metadata

type Rep LastRunInfos = D1 ('MetaData "LastRunInfos" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'False) (C1 ('MetaCons "LastRunInfos" 'PrefixI 'True) (S1 ('MetaSel ('Just "lastRun") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe LastRunInfo)) :*: S1 ('MetaSel ('Just "lastSuccessfulRun") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe LastSuccessfulRunInfo))))

loadTableLastRuns :: (Katip m, MonadIO m) => KVS -> (SpecTableName -> Ref Table) -> Map (Ref Table) NormalizedTable -> Set SpecTableName -> m TableLastRuns #

recordedRunDAG :: (HasBackendQueryStats bk, Typeable bk) => KVS -> Task (Executable bk) -> (AppName, RunId) -> (SpecTableName -> Ref Table) -> Map (Ref Table) NormalizedTable -> Combo bk (TaskResult bk) -> Combo bk (Either SomeException (TaskResult bk)) #

Do a run, recording the instance in the database. Return the recorded instance along with the run results.

data SuccessfulTaskDuration #

Constructors

SuccessfulTaskDuration AppName TaskId 

Instances

Instances details
Generic SuccessfulTaskDuration # 
Instance details

Defined in Napkin.Run.Metadata

Associated Types

type Rep SuccessfulTaskDuration 
Instance details

Defined in Napkin.Run.Metadata

type Rep SuccessfulTaskDuration = D1 ('MetaData "SuccessfulTaskDuration" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'False) (C1 ('MetaCons "SuccessfulTaskDuration" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 AppName) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 TaskId)))

Methods

from :: SuccessfulTaskDuration -> Rep SuccessfulTaskDuration x #

to :: Rep SuccessfulTaskDuration x -> SuccessfulTaskDuration #

Eq SuccessfulTaskDuration # 
Instance details

Defined in Napkin.Run.Metadata

Methods

(==) :: SuccessfulTaskDuration -> SuccessfulTaskDuration -> Bool #

(/=) :: SuccessfulTaskDuration -> SuccessfulTaskDuration -> Bool #

Ord SuccessfulTaskDuration # 
Instance details

Defined in Napkin.Run.Metadata

Methods

compare :: SuccessfulTaskDuration -> SuccessfulTaskDuration -> Ordering #

(<) :: SuccessfulTaskDuration -> SuccessfulTaskDuration -> Bool #

(<=) :: SuccessfulTaskDuration -> SuccessfulTaskDuration -> Bool #

(>) :: SuccessfulTaskDuration -> SuccessfulTaskDuration -> Bool #

(>=) :: SuccessfulTaskDuration -> SuccessfulTaskDuration -> Bool #

max :: SuccessfulTaskDuration -> SuccessfulTaskDuration -> SuccessfulTaskDuration #

min :: SuccessfulTaskDuration -> SuccessfulTaskDuration -> SuccessfulTaskDuration #

MetadataPayload SuccessfulTaskDuration SuccessfulTaskDurationInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

keyText :: SuccessfulTaskDuration -> Text #

type Rep SuccessfulTaskDuration # 
Instance details

Defined in Napkin.Run.Metadata

type Rep SuccessfulTaskDuration = D1 ('MetaData "SuccessfulTaskDuration" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'False) (C1 ('MetaCons "SuccessfulTaskDuration" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 AppName) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 TaskId)))

data SuccessfulTaskDurationInfo #

Constructors

SuccessfulTaskDurationInfo 

Fields

Instances

Instances details
FromJSON SuccessfulTaskDurationInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

parseJSON :: Value -> Parser SuccessfulTaskDurationInfo #

parseJSONList :: Value -> Parser [SuccessfulTaskDurationInfo] #

omittedField :: Maybe SuccessfulTaskDurationInfo #

ToJSON SuccessfulTaskDurationInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

toJSON :: SuccessfulTaskDurationInfo -> Value #

toEncoding :: SuccessfulTaskDurationInfo -> Encoding #

toJSONList :: [SuccessfulTaskDurationInfo] -> Value #

toEncodingList :: [SuccessfulTaskDurationInfo] -> Encoding #

omitField :: SuccessfulTaskDurationInfo -> Bool #

Default SuccessfulTaskDurationInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

def :: SuccessfulTaskDurationInfo #

Generic SuccessfulTaskDurationInfo # 
Instance details

Defined in Napkin.Run.Metadata

Associated Types

type Rep SuccessfulTaskDurationInfo 
Instance details

Defined in Napkin.Run.Metadata

type Rep SuccessfulTaskDurationInfo = D1 ('MetaData "SuccessfulTaskDurationInfo" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'False) (C1 ('MetaCons "SuccessfulTaskDurationInfo" 'PrefixI 'True) (S1 ('MetaSel ('Just "previousRuns") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Map UTCTime NominalDiffTime))))

Methods

from :: SuccessfulTaskDurationInfo -> Rep SuccessfulTaskDurationInfo x #

to :: Rep SuccessfulTaskDurationInfo x -> SuccessfulTaskDurationInfo #

MetadataPayload SuccessfulTaskDuration SuccessfulTaskDurationInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

keyText :: SuccessfulTaskDuration -> Text #

type Rep SuccessfulTaskDurationInfo # 
Instance details

Defined in Napkin.Run.Metadata

type Rep SuccessfulTaskDurationInfo = D1 ('MetaData "SuccessfulTaskDurationInfo" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'False) (C1 ('MetaCons "SuccessfulTaskDurationInfo" 'PrefixI 'True) (S1 ('MetaSel ('Just "previousRuns") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Map UTCTime NominalDiffTime))))

newtype TableLastRun #

Constructors

TableLastRun (Ref Table) 

Instances

Instances details
Generic TableLastRun # 
Instance details

Defined in Napkin.Run.Metadata

Associated Types

type Rep TableLastRun 
Instance details

Defined in Napkin.Run.Metadata

type Rep TableLastRun = D1 ('MetaData "TableLastRun" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'True) (C1 ('MetaCons "TableLastRun" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Ref Table))))

Methods

from :: TableLastRun -> Rep TableLastRun x #

to :: Rep TableLastRun x -> TableLastRun #

Eq TableLastRun # 
Instance details

Defined in Napkin.Run.Metadata

Methods

(==) :: TableLastRun -> TableLastRun -> Bool #

(/=) :: TableLastRun -> TableLastRun -> Bool #

Ord TableLastRun # 
Instance details

Defined in Napkin.Run.Metadata

Methods

compare :: TableLastRun -> TableLastRun -> Ordering #

(<) :: TableLastRun -> TableLastRun -> Bool #

(<=) :: TableLastRun -> TableLastRun -> Bool #

(>) :: TableLastRun -> TableLastRun -> Bool #

(>=) :: TableLastRun -> TableLastRun -> Bool #

max :: TableLastRun -> TableLastRun -> TableLastRun #

min :: TableLastRun -> TableLastRun -> TableLastRun #

MetadataPayload TableLastRun LastRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

keyText :: TableLastRun -> Text #

type Rep TableLastRun # 
Instance details

Defined in Napkin.Run.Metadata

type Rep TableLastRun = D1 ('MetaData "TableLastRun" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'True) (C1 ('MetaCons "TableLastRun" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Ref Table))))

data LastRunInfo #

Constructors

LastRunInfo 

Fields

Instances

Instances details
FromJSON LastRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

parseJSON :: Value -> Parser LastRunInfo #

parseJSONList :: Value -> Parser [LastRunInfo] #

omittedField :: Maybe LastRunInfo #

ToJSON LastRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

toJSON :: LastRunInfo -> Value #

toEncoding :: LastRunInfo -> Encoding #

toJSONList :: [LastRunInfo] -> Value #

toEncodingList :: [LastRunInfo] -> Encoding #

omitField :: LastRunInfo -> Bool #

Generic LastRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

Associated Types

type Rep LastRunInfo 
Instance details

Defined in Napkin.Run.Metadata

type Rep LastRunInfo = D1 ('MetaData "LastRunInfo" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'False) (C1 ('MetaCons "LastRunInfo" 'PrefixI 'True) ((S1 ('MetaSel ('Just "runId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 RunId) :*: S1 ('MetaSel ('Just "appName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 AppName)) :*: (S1 ('MetaSel ('Just "startedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :*: (S1 ('MetaSel ('Just "finishedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe UTCTime)) :*: S1 ('MetaSel ('Just "successful") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool)))))

Methods

from :: LastRunInfo -> Rep LastRunInfo x #

to :: Rep LastRunInfo x -> LastRunInfo #

Show LastRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

showsPrec :: Int -> LastRunInfo -> ShowS #

show :: LastRunInfo -> String #

showList :: [LastRunInfo] -> ShowS #

MetadataPayload TableLastRun LastRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

keyText :: TableLastRun -> Text #

type Rep LastRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

type Rep LastRunInfo = D1 ('MetaData "LastRunInfo" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'False) (C1 ('MetaCons "LastRunInfo" 'PrefixI 'True) ((S1 ('MetaSel ('Just "runId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 RunId) :*: S1 ('MetaSel ('Just "appName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 AppName)) :*: (S1 ('MetaSel ('Just "startedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :*: (S1 ('MetaSel ('Just "finishedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe UTCTime)) :*: S1 ('MetaSel ('Just "successful") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool)))))

newtype TableLastSuccessfulRun #

Constructors

TableLastSuccessfulRun (Ref Table) 

Instances

Instances details
Generic TableLastSuccessfulRun # 
Instance details

Defined in Napkin.Run.Metadata

Associated Types

type Rep TableLastSuccessfulRun 
Instance details

Defined in Napkin.Run.Metadata

type Rep TableLastSuccessfulRun = D1 ('MetaData "TableLastSuccessfulRun" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'True) (C1 ('MetaCons "TableLastSuccessfulRun" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Ref Table))))

Methods

from :: TableLastSuccessfulRun -> Rep TableLastSuccessfulRun x #

to :: Rep TableLastSuccessfulRun x -> TableLastSuccessfulRun #

Eq TableLastSuccessfulRun # 
Instance details

Defined in Napkin.Run.Metadata

Methods

(==) :: TableLastSuccessfulRun -> TableLastSuccessfulRun -> Bool #

(/=) :: TableLastSuccessfulRun -> TableLastSuccessfulRun -> Bool #

Ord TableLastSuccessfulRun # 
Instance details

Defined in Napkin.Run.Metadata

Methods

compare :: TableLastSuccessfulRun -> TableLastSuccessfulRun -> Ordering #

(<) :: TableLastSuccessfulRun -> TableLastSuccessfulRun -> Bool #

(<=) :: TableLastSuccessfulRun -> TableLastSuccessfulRun -> Bool #

(>) :: TableLastSuccessfulRun -> TableLastSuccessfulRun -> Bool #

(>=) :: TableLastSuccessfulRun -> TableLastSuccessfulRun -> Bool #

max :: TableLastSuccessfulRun -> TableLastSuccessfulRun -> TableLastSuccessfulRun #

min :: TableLastSuccessfulRun -> TableLastSuccessfulRun -> TableLastSuccessfulRun #

MetadataPayload TableLastSuccessfulRun LastSuccessfulRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

keyText :: TableLastSuccessfulRun -> Text #

type Rep TableLastSuccessfulRun # 
Instance details

Defined in Napkin.Run.Metadata

type Rep TableLastSuccessfulRun = D1 ('MetaData "TableLastSuccessfulRun" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'True) (C1 ('MetaCons "TableLastSuccessfulRun" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Ref Table))))

data LastSuccessfulRunInfo #

Constructors

LastSuccessfulRunInfo 

Fields

Instances

Instances details
FromJSON LastSuccessfulRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

parseJSON :: Value -> Parser LastSuccessfulRunInfo #

parseJSONList :: Value -> Parser [LastSuccessfulRunInfo] #

omittedField :: Maybe LastSuccessfulRunInfo #

ToJSON LastSuccessfulRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

toJSON :: LastSuccessfulRunInfo -> Value #

toEncoding :: LastSuccessfulRunInfo -> Encoding #

toJSONList :: [LastSuccessfulRunInfo] -> Value #

toEncodingList :: [LastSuccessfulRunInfo] -> Encoding #

omitField :: LastSuccessfulRunInfo -> Bool #

Generic LastSuccessfulRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

Associated Types

type Rep LastSuccessfulRunInfo 
Instance details

Defined in Napkin.Run.Metadata

type Rep LastSuccessfulRunInfo = D1 ('MetaData "LastSuccessfulRunInfo" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'False) (C1 ('MetaCons "LastSuccessfulRunInfo" 'PrefixI 'True) ((S1 ('MetaSel ('Just "runId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 RunId) :*: S1 ('MetaSel ('Just "appName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 AppName)) :*: (S1 ('MetaSel ('Just "programHash") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe ProgramHash)) :*: (S1 ('MetaSel ('Just "startedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :*: S1 ('MetaSel ('Just "finishedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime)))))

Methods

from :: LastSuccessfulRunInfo -> Rep LastSuccessfulRunInfo x #

to :: Rep LastSuccessfulRunInfo x -> LastSuccessfulRunInfo #

Show LastSuccessfulRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

showsPrec :: Int -> LastSuccessfulRunInfo -> ShowS #

show :: LastSuccessfulRunInfo -> String #

showList :: [LastSuccessfulRunInfo] -> ShowS #

MetadataPayload TableLastSuccessfulRun LastSuccessfulRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

Methods

keyText :: TableLastSuccessfulRun -> Text #

type Rep LastSuccessfulRunInfo # 
Instance details

Defined in Napkin.Run.Metadata

type Rep LastSuccessfulRunInfo = D1 ('MetaData "LastSuccessfulRunInfo" "Napkin.Run.Metadata" "napkin-runtime-2.0.0-Jnfp0IultB031hOPo9RyGD" 'False) (C1 ('MetaCons "LastSuccessfulRunInfo" 'PrefixI 'True) ((S1 ('MetaSel ('Just "runId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 RunId) :*: S1 ('MetaSel ('Just "appName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 AppName)) :*: (S1 ('MetaSel ('Just "programHash") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe ProgramHash)) :*: (S1 ('MetaSel ('Just "startedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :*: S1 ('MetaSel ('Just "finishedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime)))))

registerTaskFinished :: (Katip m, MonadIO m) => KVS -> (SpecTableName -> Ref Table) -> (AppName, RunId) -> Task (Executable bk) -> (UTCTime, UTCTime) -> Bool -> ProgramHash -> m () #

registerTaskStarted :: (Katip m, MonadIO m) => KVS -> (SpecTableName -> Ref Table) -> (AppName, RunId) -> Task (Executable bk) -> UTCTime -> m () #

loadEstimates :: (Katip m, MonadIO m) => KVS -> AppName -> TasksDAG Exec b -> m (Map TaskId NominalDiffTime) #