Skip to content

process_manager_driver

drunc.process_manager.process_manager_driver

Classes

ProcessManagerDriver(address, token)

Source code in drunc/process_manager/process_manager_driver.py 
52
53
54
55
56
57
58
59
60
def __init__(self, address: str, token: Token):
    self.log = get_logger("controller.ProcessManagerDriver")
    self.address = address
    options = [
        ("grpc.keepalive_time_ms", 60000)  # pings the server every 60 seconds
    ]
    self.channel = grpc.insecure_channel(self.address, options=options)
    self.stub = ProcessManagerStub(self.channel)
    self.token = copy_token(token)

Functions