Function annotate

packages/infra/src/WorkflowEngineCosmos.ts:164–173

(operation: string, executionId?: string)

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

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

  type Registered = {
    readonly workflow: Workflow.Any