hiro/jobmanager
1
0
Fork 0
mirror of https://github.com/vale981/jobmanager synced 2025-03-06 10:21:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

test working again, removed const_arg check for dict -> don't know why I implemented it in the first place

Browse source
This commit is contained in:
cimatosa 2015-01-14 11:13:02 +01:00
parent 2eb06686ab
commit 9d42345970
1 changed files with 5 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
jobmanager/jobmanager.py
View file

@ -22,7 +22,8 @@ __all__ = ["JobManager_Client",
"JobManager_Local", "JobManager_Local",
"JobManager_Server", "JobManager_Server",
"hashDict", "hashDict",
"hashableCopyOfNumpyArray" "hashableCopyOfNumpyArray",
"getDateForFileName"
] ]
@ -375,14 +376,8 @@ class JobManager_Server(object):
else: else:
self.authkey = bytearray(authkey, encoding='utf8') self.authkey = bytearray(authkey, encoding='utf8')
if not isinstance(const_arg, dict):
raise RuntimeError('const_arg must be an instance of dict!')
# for k in const_arg.keys(): self.const_arg = const_arg
# if not try_pickle(const_arg[k], show_exception=True):
# raise RuntimeError("key '{}' of const_arg is not pickable!\n{}={}".format(k, k, const_arg[k]))
self.const_arg = copy.copy(const_arg)
self.fname_dump = fname_dump self.fname_dump = fname_dump
@ -437,7 +432,7 @@ class JobManager_Server(object):
JobQueueManager.register('get_job_q', callable=lambda: self.job_q) JobQueueManager.register('get_job_q', callable=lambda: self.job_q)
JobQueueManager.register('get_result_q', callable=lambda: self.result_q) JobQueueManager.register('get_result_q', callable=lambda: self.result_q)
JobQueueManager.register('get_fail_q', callable=lambda: self.fail_q) JobQueueManager.register('get_fail_q', callable=lambda: self.fail_q)
JobQueueManager.register('get_const_arg', callable=lambda: self.const_arg, proxytype=mp.managers.DictProxy) JobQueueManager.register('get_const_arg', callable=lambda: self.const_arg)
address=('', self.port) #ip='' means local address=('', self.port) #ip='' means local
authkey=self.authkey authkey=self.authkey