import json
j = json.load(open('input.ipynb'))
to_del = []
for ic, c in enumerate(j["cells"]):
if c["cell_type"] == "code":
for io, o in enumerate(c["outputs"]):
if o["output_type"] == "stream" and o["name"] == "stderr":
to_del.append((ic, io))
for ic, io in sorted(to_del, reverse=True):
del j["cells"][ic]["outputs"][io]
with open('simplified.ipynb', 'w') as f:
json.dump(j, f)
"""
CLI USAGE:
python listener.py l
python listener.py c foo bar
"""
from multiprocessing.managers import SyncManager
from time import sleep
import sys
__config__ = {}
def get_config():
return __config__
def listener(address='/tmp/p2', authkey=b'password'):
SyncManager.register("get_config", get_config)
manager = SyncManager(address, authkey=authkey)
manager.start()
config = manager.get_config()
return manager, config
def controller(address='/tmp/p2', authkey=b'password'):
SyncManager.register("get_config")
manager = SyncManager(address, authkey=authkey)
manager.connect()
config = manager.get_config()
return config
if __name__ == '__main__':
if sys.argv[1] == 'l':
# from remote_control import listener
manager, config = listener()
while True:
sleep(5)
print(config)
manager.shutdown()
else:
# from remote_control import controller
config = controller()
config.update([(sys.argv[2], sys.argv[3])])