Type Alias TaskExecutionsStorageWithoutBatching

Type Declaration

• getById: (
      request: {
          executionId: string;
          filters?: TaskExecutionStorageGetByIdFilters;
      },
  ) => | TaskExecutionStorageValue
  | undefined
  | Promise<TaskExecutionStorageValue | undefined>

  Get task execution by id and optionally filter them.

• getBySleepingTaskUniqueId: (
      request: { sleepingTaskUniqueId: string },
  ) =>
      | TaskExecutionStorageValue
      | undefined
      | Promise<TaskExecutionStorageValue | undefined>

  Get task execution by sleeping task unique id.

• updateById: (
      request: {
          executionId: string;
          filters?: TaskExecutionStorageGetByIdFilters;
          update: TaskExecutionStorageUpdate;
      },
  ) => void
  | Promise<void>

  Update task execution by id and optionally filter them.

• updateByIdAndInsertChildrenIfUpdated: (
      request: {
          executionId: string;
          filters?: TaskExecutionStorageGetByIdFilters;
          update: TaskExecutionStorageUpdate;
          childrenTaskExecutionsToInsertIfAnyUpdated: ReadonlyArray<
              TaskExecutionStorageValue,
          >;
      },
  ) => void
  | Promise<void>

  Update task execution by id and insert children task executions if updated.

• getByParentExecutionId: (
      request: { parentExecutionId: string },
  ) => TaskExecutionStorageValue[] | Promise<TaskExecutionStorageValue[]>

  Get task executions by parent execution id.

• updateByParentExecutionIdAndIsFinished: (
      request: {
          parentExecutionId: string;
          isFinished: boolean;
          update: TaskExecutionStorageUpdate;
      },
  ) => void
  | Promise<void>

  Update task executions by parent execution id and is finished.