klio message

klio message

Manage a job’s message queue via Pub/Sub.

klio message [OPTIONS] COMMAND [ARGS]...


Publish a message(s) to a running job.

klio message publish [OPTIONS] ENTITY_IDS...


-f, --force

Force processing even if output data exists.

-p, --ping

Skip the processing of an ID to trace the path the ID takes.

-t, --top-down

Trigger an apex node and all child nodes below. Default: False

-b, --bottom-up

Trigger work for only this job and any required parent jobs, but no sibling or child jobs. Default: True

-n, --non-klio

Publish a free-form, non-Klio message to the targeted job. The targeted job must also support non-Klio messages. Mutually exclusive with --force, --ping, and --bottom-up. Default: False

-O, --override <override>

Override a config value, in the form key=value.

-T, --template <template>

Set the value of a config template parameter, in the form key=value. Any instance of ${key} in klio-job.yaml will be replaced with value.

-j, --job-dir <job_dir>

Job directory where the job’s Dockerfile is located. Defaults current working directory.

-c, --config-file <config_file>

Path to config filename. If PATH is not absolute, it will be treated relative to --job-dir. Defaults to klio-job.yaml.



Required argument(s)