deepinsight.base package

Submodules

deepinsight.base.java_link module

class deepinsight.base.java_link.JavaLink(port, secret)

Bases: object

Link to the backend over a socket

close()

Close the socket (use send_string(‘’) to send end of stream to backend)

connect()

Initiate connection

get_command()

Get the command to process, as an object

get_input()

Get the data sent by the backend

get_output()

Get the stream to write the result to the backend

read_block()

Get the next block from the backend

read_json()

send_block(b)

Send a block to the backend

send_json(o)

send_string(s)

class deepinsight.base.java_link.LinkedInputStream(link)

Bases: io.RawIOBase

next_block()

readable()

readinto(b)

class deepinsight.base.java_link.LinkedOutputStream(link)

Bases: io.RawIOBase

Unbuffered stream to the backend

flush()

writable()

write(b)

deepinsight.base.remoterun module

deepinsight.base.remoterun.get_dtflow_spec(no_fail=True)

deepinsight.base.remoterun.get_env_var(k, d=<object object>, no_fail=True)

deepinsight.base.remoterun.get_env_vars(no_fail=True)

deepinsight.base.remoterun.get_remote_run_env_def(no_fail=True)

deepinsight.base.remoterun.has_env_var(k, no_fail=True)

deepinsight.base.remoterun.read_dt_env_and_set(no_fail=True, force=False)

deepinsight.base.remoterun.safe_os_environ_update(added)

deepinsight.base.remoterun.set_dt_env_var_and_sys_env_var(k, v, no_fail=True)

deepinsight.base.utils module

DeepInsight utilities

deepinsight.base.utils.get_json_friendly_error()

deepinsight.base.utils.package_is_at_least(p, min_version)

deepinsight.base.utils.safe_unicode_str(o)

deepinsight.base.utils.smart_decode_str(o)

deepinsight.base.utils.watch_stdin()

Starts a thread which watches stdin and exits the process when it closes so as not to survive the parent backend

Module contents