dml_util.lib.submit

dml_util.lib.submit#

Functions

launch_detached(cmd[, env])

Fire-and-forget.

Classes

Streamer(log_group_name, log_stream_name, ...)

class dml_util.lib.submit.Streamer(log_group_name: str, log_stream_name: str, fd: <class 'TextIO'>, run_id: str = <factory>, send_interval: float = 5.0, max_events: int = 10000, log_buffer: list = <factory>, buffer_lock: _thread.lock = <factory>, stop: threading.Event = <factory>, client: <function client at 0x7f6ce3866660> = <factory>)[source]#

Bases: object

Parameters:

  • log_group_name (str)

  • log_stream_name (str)

  • fd (TextIO)

  • run_id (str)

  • send_interval (float)

  • max_events (int)

  • log_buffer (list)

  • buffer_lock (lock)

  • stop (Event)

  • client (client)

buffer_lock: lock#
client: client#
fd: TextIO#
join()[source]#
log_buffer: list#
log_group_name: str#
log_stream_name: str#
max_events: int = 10000#
put(message)[source]#
Parameters:

message (str)

run()[source]#
run_id: str#
send_interval: float = 5.0#
stop: Event#
thread: Thread#
dml_util.lib.submit.launch_detached(cmd, env=None)[source]#

Fire-and-forget. Returns immediately. The background helper keeps running after this script exits.

launch_detached([“python”, “train.py”], “my-logs”, “exec/42”)

Contents