66 < head >
77 < meta http-equiv ="X-UA-Compatible " content ="IE=Edge " />
88 < meta http-equiv ="Content-Type " content ="text/html; charset=utf-8 " />
9- < title > tensorflowonspark.TFManager — TensorFlowOnSpark 1.3.0 documentation</ title >
9+ < title > tensorflowonspark.TFManager — TensorFlowOnSpark 1.3.1 documentation</ title >
1010 < link rel ="stylesheet " href ="../../_static/classic.css " type ="text/css " />
1111 < link rel ="stylesheet " href ="../../_static/pygments.css " type ="text/css " />
1212 < script type ="text/javascript " src ="../../_static/documentation_options.js "> </ script >
@@ -25,7 +25,7 @@ <h3>Navigation</h3>
2525 < li class ="right " >
2626 < a href ="../../py-modindex.html " title ="Python Module Index "
2727 > modules</ a > |</ li >
28- < li class ="nav-item nav-item-0 "> < a href ="../../index.html "> TensorFlowOnSpark 1.3.0 documentation</ a > »</ li >
28+ < li class ="nav-item nav-item-0 "> < a href ="../../index.html "> TensorFlowOnSpark 1.3.1 documentation</ a > »</ li >
2929 < li class ="nav-item nav-item-1 "> < a href ="../index.html " accesskey ="U "> Module code</ a > »</ li >
3030 </ ul >
3131 </ div >
@@ -48,6 +48,7 @@ <h1>Source code for tensorflowonspark.TFManager</h1><div class="highlight"><pre>
4848< span class ="kn "> from</ span > < span class ="nn "> multiprocessing.managers</ span > < span class ="k "> import</ span > < span class ="n "> BaseManager</ span >
4949< span class ="kn "> from</ span > < span class ="nn "> multiprocessing</ span > < span class ="k "> import</ span > < span class ="n "> JoinableQueue</ span >
5050
51+
5152< div class ="viewcode-block " id ="TFManager "> < a class ="viewcode-back " href ="../../tensorflowonspark.TFManager.html#tensorflowonspark.TFManager.TFManager "> [docs]</ a > < span class ="k "> class</ span > < span class ="nc "> TFManager</ span > < span class ="p "> (</ span > < span class ="n "> BaseManager</ span > < span class ="p "> ):</ span >
5253 < span class ="sd "> """Python multiprocessing.Manager for distributed, multi-process communication."""</ span > </ div >
5354 < span class ="k "> pass</ span >
@@ -58,18 +59,22 @@ <h1>Source code for tensorflowonspark.TFManager</h1><div class="highlight"><pre>
5859< span class ="n "> qdict</ span > < span class ="o "> =</ span > < span class ="p "> {}</ span > < span class ="c1 "> # dictionary of queues</ span >
5960< span class ="n "> kdict</ span > < span class ="o "> =</ span > < span class ="p "> {}</ span > < span class ="c1 "> # dictionary of key-values</ span >
6061
62+
6163< span class ="k "> def</ span > < span class ="nf "> _get</ span > < span class ="p "> (</ span > < span class ="n "> key</ span > < span class ="p "> ):</ span >
6264 < span class ="k "> return</ span > < span class ="n "> kdict</ span > < span class ="p "> [</ span > < span class ="n "> key</ span > < span class ="p "> ]</ span >
6365
66+
6467< span class ="k "> def</ span > < span class ="nf "> _set</ span > < span class ="p "> (</ span > < span class ="n "> key</ span > < span class ="p "> ,</ span > < span class ="n "> value</ span > < span class ="p "> ):</ span >
6568 < span class ="n "> kdict</ span > < span class ="p "> [</ span > < span class ="n "> key</ span > < span class ="p "> ]</ span > < span class ="o "> =</ span > < span class ="n "> value</ span >
6669
70+
6771< span class ="k "> def</ span > < span class ="nf "> _get_queue</ span > < span class ="p "> (</ span > < span class ="n "> qname</ span > < span class ="p "> ):</ span >
6872 < span class ="k "> try</ span > < span class ="p "> :</ span >
6973 < span class ="k "> return</ span > < span class ="n "> qdict</ span > < span class ="p "> [</ span > < span class ="n "> qname</ span > < span class ="p "> ]</ span >
7074 < span class ="k "> except</ span > < span class ="ne "> KeyError</ span > < span class ="p "> :</ span >
7175 < span class ="k "> return</ span > < span class ="kc "> None</ span >
7276
77+
7378< div class ="viewcode-block " id ="start "> < a class ="viewcode-back " href ="../../tensorflowonspark.TFManager.html#tensorflowonspark.TFManager.start "> [docs]</ a > < span class ="k "> def</ span > < span class ="nf "> start</ span > < span class ="p "> (</ span > < span class ="n "> authkey</ span > < span class ="p "> ,</ span > < span class ="n "> queues</ span > < span class ="p "> ,</ span > < span class ="n "> mode</ span > < span class ="o "> =</ span > < span class ="s1 "> 'local'</ span > < span class ="p "> ):</ span >
7479 < span class ="sd "> """Create a new multiprocess.Manager (or return existing one).</ span >
7580
@@ -91,12 +96,13 @@ <h1>Source code for tensorflowonspark.TFManager</h1><div class="highlight"><pre>
9196 < span class ="n "> TFManager</ span > < span class ="o "> .</ span > < span class ="n "> register</ span > < span class ="p "> (</ span > < span class ="s1 "> 'get'</ span > < span class ="p "> ,</ span > < span class ="n "> callable</ span > < span class ="o "> =</ span > < span class ="k "> lambda</ span > < span class ="n "> key</ span > < span class ="p "> :</ span > < span class ="n "> _get</ span > < span class ="p "> (</ span > < span class ="n "> key</ span > < span class ="p "> ))</ span >
9297 < span class ="n "> TFManager</ span > < span class ="o "> .</ span > < span class ="n "> register</ span > < span class ="p "> (</ span > < span class ="s1 "> 'set'</ span > < span class ="p "> ,</ span > < span class ="n "> callable</ span > < span class ="o "> =</ span > < span class ="k "> lambda</ span > < span class ="n "> key</ span > < span class ="p "> ,</ span > < span class ="n "> value</ span > < span class ="p "> :</ span > < span class ="n "> _set</ span > < span class ="p "> (</ span > < span class ="n "> key</ span > < span class ="p "> ,</ span > < span class ="n "> value</ span > < span class ="p "> ))</ span >
9398 < span class ="k "> if</ span > < span class ="n "> mode</ span > < span class ="o "> ==</ span > < span class ="s1 "> 'remote'</ span > < span class ="p "> :</ span >
94- < span class ="n "> mgr</ span > < span class ="o "> =</ span > < span class ="n "> TFManager</ span > < span class ="p "> (</ span > < span class ="n "> address</ span > < span class ="o "> =</ span > < span class ="p "> (</ span > < span class ="s1 "> ''</ span > < span class ="p "> ,</ span > < span class ="mi "> 0</ span > < span class ="p "> ),</ span > < span class ="n "> authkey</ span > < span class ="o "> =</ span > < span class ="n "> authkey</ span > < span class ="p "> )</ span >
99+ < span class ="n "> mgr</ span > < span class ="o "> =</ span > < span class ="n "> TFManager</ span > < span class ="p "> (</ span > < span class ="n "> address</ span > < span class ="o "> =</ span > < span class ="p "> (</ span > < span class ="s1 "> ''</ span > < span class ="p "> ,</ span > < span class ="mi "> 0</ span > < span class ="p "> ),</ span > < span class ="n "> authkey</ span > < span class ="o "> =</ span > < span class ="n "> authkey</ span > < span class ="p "> )</ span >
95100 < span class ="k "> else</ span > < span class ="p "> :</ span >
96101 < span class ="n "> mgr</ span > < span class ="o "> =</ span > < span class ="n "> TFManager</ span > < span class ="p "> (</ span > < span class ="n "> authkey</ span > < span class ="o "> =</ span > < span class ="n "> authkey</ span > < span class ="p "> )</ span >
97102 < span class ="n "> mgr</ span > < span class ="o "> .</ span > < span class ="n "> start</ span > < span class ="p "> ()</ span > </ div >
98103 < span class ="k "> return</ span > < span class ="n "> mgr</ span >
99104
105+
100106< div class ="viewcode-block " id ="connect "> < a class ="viewcode-back " href ="../../tensorflowonspark.TFManager.html#tensorflowonspark.TFManager.connect "> [docs]</ a > < span class ="k "> def</ span > < span class ="nf "> connect</ span > < span class ="p "> (</ span > < span class ="n "> address</ span > < span class ="p "> ,</ span > < span class ="n "> authkey</ span > < span class ="p "> ):</ span >
101107 < span class ="sd "> """Connect to a multiprocess.Manager.</ span >
102108
@@ -113,7 +119,6 @@ <h1>Source code for tensorflowonspark.TFManager</h1><div class="highlight"><pre>
113119 < span class ="n "> m</ span > < span class ="o "> =</ span > < span class ="n "> TFManager</ span > < span class ="p "> (</ span > < span class ="n "> address</ span > < span class ="p "> ,</ span > < span class ="n "> authkey</ span > < span class ="o "> =</ span > < span class ="n "> authkey</ span > < span class ="p "> )</ span >
114120 < span class ="n "> m</ span > < span class ="o "> .</ span > < span class ="n "> connect</ span > < span class ="p "> ()</ span > </ div >
115121 < span class ="k "> return</ span > < span class ="n "> m</ span >
116-
117122</ pre > </ div >
118123
119124 </ div >
@@ -146,12 +151,12 @@ <h3>Navigation</h3>
146151 < li class ="right " >
147152 < a href ="../../py-modindex.html " title ="Python Module Index "
148153 > modules</ a > |</ li >
149- < li class ="nav-item nav-item-0 "> < a href ="../../index.html "> TensorFlowOnSpark 1.3.0 documentation</ a > »</ li >
154+ < li class ="nav-item nav-item-0 "> < a href ="../../index.html "> TensorFlowOnSpark 1.3.1 documentation</ a > »</ li >
150155 < li class ="nav-item nav-item-1 "> < a href ="../index.html " > Module code</ a > »</ li >
151156 </ ul >
152157 </ div >
153158 < div class ="footer " role ="contentinfo ">
154- © Copyright 2017 , Yahoo Inc.
159+ © Copyright 2018 , Yahoo Inc.
155160 Created using < a href ="http://sphinx-doc.org/ "> Sphinx</ a > 1.7.1.
156161 </ div >
157162 </ body >
0 commit comments