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...
Options
-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
False
-b
--bottom-up
Trigger work for only this job and any required parent jobs, but no sibling or child jobs. Default: True
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.
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.
${key}
klio-job.yaml
value
-j
--job-dir
<job_dir>
Job directory where the job’s Dockerfile is located. Defaults current working directory.
Dockerfile
-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.
PATH
Arguments
ENTITY_IDS
Required argument(s)