klio_core.options
klio_core.options.
image_tag
Docker image tag to use.
direct_runner
Run the job locally via the DirectRunner.
update
[Experimental] Update an existing streaming Cloud Dataflow job.
show_logs
Show a job’s logs while profiling.
interval
Sampling period (in seconds).
include_children
Monitor forked processes as well (sums up all process memory).
multiprocess
Monitor forked processes creating individual plots for each child.
plot_graph
Plot memory profile using matplotlib. Saves to klio_profile_memory_<YYYYMMDDhhmmss>.png
maximum
Print maximum memory usage per line in aggregate of all input elements processed
per_element
Print memory usage per line for each input element processed
iterations
Number of times to execute each entity ID provided.