Loading bin/acn_load_images +4 −0 Original line number Diff line number Diff line Loading @@ -123,4 +123,8 @@ if __name__ == '__main__': msg = pop_computetime_push(queue, conf['processing_queue'], conf['working_queue']) if msg is None: warnings.warn('Expected to process a cluster job, but the message queue is empty.') sys.exit() main(msg, config) bin/acn_overlaps +3 −0 Original line number Diff line number Diff line Loading @@ -50,5 +50,8 @@ if __name__ == '__main__': msg = pop_computetime_push(queue, conf['processing_queue'], conf['working_queue']) if msg is None: warnings.warn('Expected to process a cluster job, but the message queue is empty.') sys.exit() main(msg, config) bin/acn_submit +3 −1 Original line number Diff line number Diff line Loading @@ -57,7 +57,9 @@ if __name__ == '__main__': msg = pop_computetime_push(queue, conf['processing_queue'], conf['working_queue']) if msg is None: warnings.warn('Expected to process a cluster job, but the message queue is empty.') sys.exit() # In order to pop an entry off the queue, we need the exact contents #remove_key = copy.deepcopy(msg) Loading Loading
bin/acn_load_images +4 −0 Original line number Diff line number Diff line Loading @@ -123,4 +123,8 @@ if __name__ == '__main__': msg = pop_computetime_push(queue, conf['processing_queue'], conf['working_queue']) if msg is None: warnings.warn('Expected to process a cluster job, but the message queue is empty.') sys.exit() main(msg, config)
bin/acn_overlaps +3 −0 Original line number Diff line number Diff line Loading @@ -50,5 +50,8 @@ if __name__ == '__main__': msg = pop_computetime_push(queue, conf['processing_queue'], conf['working_queue']) if msg is None: warnings.warn('Expected to process a cluster job, but the message queue is empty.') sys.exit() main(msg, config)
bin/acn_submit +3 −1 Original line number Diff line number Diff line Loading @@ -57,7 +57,9 @@ if __name__ == '__main__': msg = pop_computetime_push(queue, conf['processing_queue'], conf['working_queue']) if msg is None: warnings.warn('Expected to process a cluster job, but the message queue is empty.') sys.exit() # In order to pop an entry off the queue, we need the exact contents #remove_key = copy.deepcopy(msg) Loading