Bulk Add Queue Items

Adds up to 1000 items to a queue in one call, one per data table row or list element. Reference, Priority, DeferUntil and Deadline columns set those fields; the rest is the payload.

Behaviour

Risk: Low · Idempotent: No · Safe to retry: No · Recovery: Not replayed after a crash

Package Orchestrator activities VeloPhex.Orchestrator.Activities 0.7.1-rc.12 · Supported (Core profile) · type id velophex.orchestrator.bulkAddQueueItems

Properties#

Input#

Queue Name#

QueueName · String · Required · Default: Not specified in package metadata

The name of the queue in the job's workspace.

Data Table#

DataTable · DataTable · Optional · Default: Not specified in package metadata

One item per row. Reference, Priority, DeferUntil and Deadline columns set those fields; the other columns form the payload.

Items#

Items · IEnumerable<Object> · Optional · Default: Not specified in package metadata

One item per element: a JSON text, or an object whose Reference, Priority, DeferUntil and Deadline properties set those fields and the rest form the payload.

Commit Type#

CommitType · String · Optional · Default: AllOrNothing

AllOrNothing adds nothing and faults when one item is refused; ProcessIndependently adds the valid items and reports the rest in Errors.

Allowed values: AllOrNothing, ProcessIndependently.

Output#

Committed#

Committed · Boolean · Output

False when nothing was added.

Added Item Ids#

AddedItemIds · IReadOnlyList<String> · Output

The identifiers of the added items, in input order.

Errors#

Errors · IReadOnlyList<String> · Output

One line per refused item: its 0-based position, the field at fault and why.

Rules#

  • Set only one of: Data Table, Items.

Retry and risk#

This activity is not marked safe to retry: if it fails partway, check whether its work already happened before running it again. If a run is interrupted and the outcome of a step is unknown, the step is never retried automatically (what to do). How activities declare this: characteristics, retries and risk.

Every activity also has the engine's common properties: Timeout and Continue On Error.

Generated from VeloPhex.Orchestrator.Activities 0.7.1-rc.12. Category: Queues. Keywords: queue, items, bulk, batch, enqueue, add, data table, upload, transaction, orchestrator.

Properties

Input

Output

Rules

Retry and risk

Related activities