Queue
Manage work queues for distributed processing - add items, get next item, and track processing state.
Overview
The Queue package provides work queue management for distributed automation. Use it when you need to queue work items for processing, distribute work across multiple robots, or track the status of processed items.
Key Features
- Item Management - Add, get, and delete queue items
- State Tracking - Track item processing status
- Distributed Processing - Enable multiple robots to process queues
- Wait Operations - Wait for new items to arrive
Available Nodes
- Add Item - Add a new item to the queue
- Get Next Item - Get the next unprocessed item
- Get Items - Get all items or filter by state
- Update Item State - Update the processing state of an item
- Delete Item - Remove an item from the queue
- Wait Item - Wait for a new item to arrive
When to Use This Package
- Batch Processing: Queue items for sequential processing
- Distributed Work: Split work across multiple robots
- Asynchronous Processing: Decouple item collection from processing
- Error Handling: Retry failed items from queue
Item States
- New - Not yet processed
- In Progress - Currently being processed
- Completed - Successfully processed
- Failed - Processing failed
Typical Workflow
- Add Item to queue (from one workflow)
- Get Next Item to retrieve work (from processing workflow)
- Process the item
- Update Item State to mark success/failure
Use Cases
- Queue orders for processing by warehouse robots
- Distribute lead processing across multiple robots
- Retry failed operations from a queue
- Buffer incoming requests for batch processing
- Track processing status of work items
📄️ Add Item
Core.Queue.Add
📄️ Delete Item
Core.Queue.Delete
📄️ Get Items
Core.Queue.GetAll
📄️ Get Next Item
Get Next Item node
📄️ Update Item State
Core.Queue.Update
📄️ Wait Item
Core.Queue.Wait