Commit 1cba661d authored by Jay Laura's avatar Jay Laura Committed by jay
Browse files

updates for remote processing

parent 8c379bd0

autocnet/graph/asynchronous_funcs.py

+1 −1
Original line number Diff line number Diff line
@@ -135,7 +135,7 @@ def watch_insert_queue(queue, queue_name, counter_name, engine, stop_event, slee 
                    pipe.incr(counter_name)

                msgs = pipe.execute()

            except:

                warnings.warn('Failed to push to DB and failed to repopulate queue.)

                warnings.warn('Failed to push to DB and failed to repopulate queue.')

                time.sleep(5)



def watch_update_queue(queue, queue_name, counter_name, engine, stop_event, sleep_time=5):

autocnet/graph/cluster_submit_single.py

+3 −2
Original line number Diff line number Diff line
@@ -91,7 +91,8 @@ def process(msg): 


def main():

    msg = ''.join(sys.argv[1:])

    process(msg)

    result = process(msg)

    print(result)

    

if __name__ == '__main__':

    main()