readJournal method

  1. @override
Future<WorkflowJournalSnapshot?> readJournal(
  1. String runId,
  2. WorkflowJournalKind kind,
  3. String name
)
override

Reads current run state and a record, or null if the run does not exist.

Implementation

@override
Future<WorkflowJournalSnapshot?> readJournal(
  String runId,
  WorkflowJournalKind kind,
  String name,
) async {
  final run = _readRunState(runId);
  if (run == null) return null;
  return WorkflowJournalSnapshot(
    run: run,
    entry: _journal[runId]?[(kind, name)],
  );
}