diff options
author | Luciano Resende <lresende@apache.org> | 2017-01-19 12:39:03 -0800 |
---|---|---|
committer | Luciano Resende <lresende@apache.org> | 2017-01-23 11:10:04 -0800 |
commit | 78920739e7f5c3e1ee6d6c4632e513aabf108eb2 (patch) | |
tree | e083c557ff6a77e78ff56980d2a31a9c5d4d68f1 /python/toree_profile.py | |
parent | f378b236663cef80a02215714e7b5590fdc8e26b (diff) | |
download | toree-gateway-78920739e7f5c3e1ee6d6c4632e513aabf108eb2.tar.gz toree-gateway-78920739e7f5c3e1ee6d6c4632e513aabf108eb2.tar.bz2 toree-gateway-78920739e7f5c3e1ee6d6c4632e513aabf108eb2.zip |
Lifecycle management for Toree Gateway
The lifecycle enables starting/stopping the
remote Toree instance when a Notebook is
started/stopped.
This also includes other minor changes to
support Python 3.5.x
Diffstat (limited to 'python/toree_profile.py')
-rw-r--r-- | python/toree_profile.py | 78 |
1 files changed, 78 insertions, 0 deletions
diff --git a/python/toree_profile.py b/python/toree_profile.py new file mode 100644 index 0000000..eaadc9d --- /dev/null +++ b/python/toree_profile.py @@ -0,0 +1,78 @@ +# +# (C) Copyright IBM Corp. 2017 +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + + +import os +import os.path +import json +import time + +class Profile: + PROCESS_FILE_NAME = "toree.pid" + CONFIGURATION_FILE_NAME = "profile.json" + + profilePath = None + + def __init__(self, profilePath): + self.profilePath = profilePath + + def pidLocation(self): + return self.profilePath + '/' + self.PROCESS_FILE_NAME + + def configurationLocation(self): + return self.profilePath + '/' + self.CONFIGURATION_FILE_NAME + + def isAvailable(self): + taken = os.path.exists(self.pidLocation()) + return not taken + + def reserve(self): + open(self.pidLocation(), 'a').close() + + def release(self): + if os.path.exists(self.pidLocation()): + os.remove(self.pidLocation()) + + def pid(self): + with open(self.pidLocation(), 'r') as pid_file: + data = pid_file.read() + return data + + def updatePid(self, pid): + try: + file = open(self.pidLocation(), 'w') + file.write(pid) + finally: + file.close + + def config(self): + with open(self.configurationLocation(), 'r') as data_file: + return json.load(data_file) #, object_hook=util._byteify + + + +""" +p = Profile('/Users/lresende/opensource/jupyter/toree-gateway/src/main/resources/profiles/kernel-1') +print(p.pidLocation()) +print(p.configurationLocation()) +print(p.isAvailable()) +c = p.config() +print(c['stdin_port']) +p.reserve() +time.sleep(10) +p.release() +""" + |