Function annotate

packages/infra/src/WorkflowEngineSqlite.ts:143–150

(operation: string, executionId?: string)

  const clockPollInterval = cfg.clockPollInterval ?? Duration.seconds(5)

  const annotate = (operation: string, executionId?: string) =>
    annotateDb({
      operation,
      system: "sqlite",
      collection: execTable,
      entity: "workflow",
      extra: executionId !== undefined ? { "app.entity.id": executionId } : undefined
    })

  const exec = (query: string, params: ReadonlyArray<unknown> = []) =>
    sql.unsafe(query, params as Array<any>).pipe(Effect.orDie)