diff options
Diffstat (limited to 'monitor/josef_mover.py')
| -rwxr-xr-x | monitor/josef_mover.py | 14 |
1 files changed, 3 insertions, 11 deletions
diff --git a/monitor/josef_mover.py b/monitor/josef_mover.py index 8d566cc..d3532a1 100755 --- a/monitor/josef_mover.py +++ b/monitor/josef_mover.py @@ -225,7 +225,7 @@ def check_stress_submission(first, last, source, dest, logfile): try: entries = [] while len(entries) < last - first: - print "Getting " + str(first + len(entries)) + " to " + str(last) + # print "Getting " + str(first + len(entries)) + " to " + str(last) entries += get_entries(s_log["url"], first + len(entries), last)["entries"] # print "Fetched entries up to " + str(len(first + len(entries))) except: @@ -284,14 +284,6 @@ def stress_test(dest): for p in processes: p.join() - # print "Done!" - - - # TODO get entries from log - # TODO parallellize - # TODO submit really fast - # TODO catch errors - pass def log(fn, string): @@ -303,10 +295,10 @@ def log(fn, string): if __name__ == "__main__": - source = [CTLOGS[3]] + source = [CTLOGS[2]] dests = CTLOGS - stress_test([CTLOGS[0]]) + stress_test([CTLOGS[2]]) # check_overlap(source, dests) |