schrodinger.seam.viz.watcherd module

Launch a background process that manages the seamwatcher directory used for monitoring and visualizing workflows

schrodinger.seam.viz.watcherd.is_daemon_enabled()
class schrodinger.seam.viz.watcherd.Watcher(running_pipelines_dir: pathlib.Path = PosixPath('/home/buildbot/.seamwatcher/running_pipelines'), complete_pipelines_dir: pathlib.Path = PosixPath('/home/buildbot/.seamwatcher/complete_pipelines'), metadata_file: pathlib.Path = PosixPath('/home/buildbot/.seamwatcher/pipeline_metadata.json'))

Bases: object

__init__(running_pipelines_dir: pathlib.Path = PosixPath('/home/buildbot/.seamwatcher/running_pipelines'), complete_pipelines_dir: pathlib.Path = PosixPath('/home/buildbot/.seamwatcher/complete_pipelines'), metadata_file: pathlib.Path = PosixPath('/home/buildbot/.seamwatcher/pipeline_metadata.json'))
classmethod fromDirectory(directory: pathlib.Path)
update_pipeline_jobs()

Parse the raw output of a $SCHRODINGER/jsc list JSON dump of jobs for jobs originally launched from LiveDesign. All LiveDesign jobs contain the environment variable SCHRODINGER_JOB_METADATA.

Parameters

dump – the raw stdout of the jsc command

Returns

a list of dicts where each dict is a JSON dump of the job

cleanUpCompletePipelinesDir()
Clean up the complete pipelines directory by removing any symlinks that
  1. Point to non-existent directories.

  2. Point to directories that do not contain a seam/.events file

start()
schrodinger.seam.viz.watcherd.get_parser() argparse.ArgumentParser
schrodinger.seam.viz.watcherd.process_namespace(namespace: argparse.Namespace)

Process the namespace doing any further verificaiton and setting of defaults

schrodinger.seam.viz.watcherd.main(args: Optional[List] = None)