openaleph-procrastinate
No description available
Usage
openaleph-procrastinate [OPTIONS] COMMAND [ARGS]...
Arguments
No arguments available
Options
| Name | Description | Required | Default |
|---|---|---|---|
--version / --no-version |
Show version [default: no-version] | No | - |
--settings / --no-settings |
Show current settings [default: no-settings] | No | - |
--install-completion |
Install completion for the current shell. | No | - |
--show-completion |
Show completion for the current shell, to copy it or customize the installation. | No | - |
--help |
Show this message and exit. | No | - |
Commands
| Name | Description |
|---|---|
defer-entities |
Defer jobs for a stream of proxies |
defer-jobs |
Defer jobs from an input json stream |
init-db |
Initialize procrastinate database schema |
ensure-indexes |
Ensure desired indexes exist and drop... |
requeue-failed |
Requeue failed jobs matching the given... |
requeue-stalled |
Requeue stalled/orphaned jobs matching the... |
Subcommands
openaleph-procrastinate defer-entities
Defer jobs for a stream of proxies
Usage
openaleph-procrastinate defer-entities [OPTIONS]
Arguments
No arguments available
Options
| Name | Description | Required | Default |
|---|---|---|---|
-i TEXT |
Input uri, default stdin [default: -] | No | - |
-d TEXT |
Dataset | Yes | - |
-q TEXT |
Queue name | Yes | - |
-t TEXT |
Task module path | Yes | - |
--help |
Show this message and exit. | No | - |
openaleph-procrastinate defer-jobs
Defer jobs from an input json stream
Usage
openaleph-procrastinate defer-jobs [OPTIONS]
Arguments
No arguments available
Options
| Name | Description | Required | Default |
|---|---|---|---|
-i TEXT |
Input uri, default stdin [default: -] | No | - |
--help |
Show this message and exit. | No | - |
openaleph-procrastinate init-db
Initialize procrastinate database schema
Usage
openaleph-procrastinate init-db [OPTIONS]
Arguments
No arguments available
Options
| Name | Description | Required | Default |
|---|---|---|---|
--help |
Show this message and exit. | No | - |
openaleph-procrastinate ensure-indexes
Ensure desired indexes exist and drop stale ones.
Runs db.configure() to create desired schema and indexes, then drops any indexes on procrastinate_jobs not in the known-good set.
Use --force to drop and recreate all custom indexes.
Usage
openaleph-procrastinate ensure-indexes [OPTIONS]
Arguments
No arguments available
Options
| Name | Description | Required | Default |
|---|---|---|---|
--force |
Drop and recreate all custom indexes | No | - |
--help |
Show this message and exit. | No | - |
openaleph-procrastinate requeue-failed
Requeue failed jobs matching the given filters.
This command finds all jobs with status='failed' that match the optional filters (dataset, queue, task) and retries them by setting their status back to 'todo'.
Usage
openaleph-procrastinate requeue-failed [OPTIONS]
Arguments
No arguments available
Options
| Name | Description | Required | Default |
|---|---|---|---|
-d TEXT |
Dataset | No | - |
-q TEXT |
Queue name | No | - |
-t TEXT |
Task module path | No | - |
--help |
Show this message and exit. | No | - |
openaleph-procrastinate requeue-stalled
Requeue stalled/orphaned jobs matching the given filters.
This command finds all jobs with status='doing' whose worker no longer exists (orphaned jobs) and retries them by setting their status back to 'todo'.
Orphaned jobs can occur when the foreign key constraint on worker_id is dropped (for performance) and workers are pruned before completing their jobs.
Usage
openaleph-procrastinate requeue-stalled [OPTIONS]
Arguments
No arguments available
Options
| Name | Description | Required | Default |
|---|---|---|---|
-d TEXT |
Dataset | No | - |
-q TEXT |
Queue name | No | - |
-t TEXT |
Task module path | No | - |
--help |
Show this message and exit. | No | - |