klio_core.options

klio_core.options.image_tag(*args, **kwargs)

Docker image tag to use.

klio_core.options.direct_runner(func)

Run the job locally via the DirectRunner.

klio_core.options.update(func)

[Experimental] Update an existing streaming Cloud Dataflow job.

klio_core.options.show_logs(func)

Show a job’s logs while profiling.

klio_core.options.interval(func)

Sampling period (in seconds).

klio_core.options.include_children(func)

Monitor forked processes as well (sums up all process memory).

klio_core.options.multiprocess(func)

Monitor forked processes creating individual plots for each child.

klio_core.options.plot_graph(func)

Plot memory profile using matplotlib. Saves to klio_profile_memory_<YYYYMMDDhhmmss>.png

klio_core.options.maximum(func)

Print maximum memory usage per line in aggregate of all input elements processed

klio_core.options.per_element(*args, **kwargs)

Print memory usage per line for each input element processed

klio_core.options.iterations(func)

Number of times to execute each entity ID provided.