Skip to content

Commit

Permalink
fix style
Browse files Browse the repository at this point in the history
  • Loading branch information
weaverba137 committed Aug 20, 2024
1 parent 595213c commit 37aa3f3
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 5 deletions.
2 changes: 1 addition & 1 deletion doc/changes.rst
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ Change Log
1.0.3 (unreleased)
------------------

* No changes yet.
* Convert Tucson transfer to parallel operation.

1.0.2 (2024-06-21)
------------------
Expand Down
1 change: 0 additions & 1 deletion py/desitransfer/test/test_tucson.py
Original file line number Diff line number Diff line change
Expand Up @@ -196,4 +196,3 @@ def test_get_proc(self, mock_log, mock_popen):
self.assertEqual(d, 'i')
proc, LOG_J, d = _get_proc(directories, exclude, '/src', '/dst', options)
self.assertIsNone(proc)

8 changes: 5 additions & 3 deletions py/desitransfer/tucson.py
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@ def _options():
default=os.path.join(os.environ['HOME'], 'Documents', 'Logfiles'),
help='Use DIR for log files (default %(default)s).')
prsr.add_argument('-p', '--processes', action='store', type=int,
dest='nproc', metavar="N", default=10,
dest='nproc', metavar="N", default=10,
help="Number of simultaneous downloads (default %(default)s).")
prsr.add_argument('-s', '--static', action='store_true', dest='static',
help='Also sync static data sets.')
Expand Down Expand Up @@ -327,6 +327,8 @@ def main():
LOG.close()
if status != 0:
log.critical("rsync error detected for %s/%s/! Check logs!", dst, d)
proc_pool[proc_key] = _get_proc(directories, exclude, src, dst, options)
time.sleep(sleepy_time)
proc_pool[proc_key] = _get_proc(directories, exclude, src, dst, options)
if not options.test:
log.debug("Waiting for jobs to complete, sleeping %s.", options.sleep)
time.sleep(sleepy_time)
return 0

0 comments on commit 37aa3f3

Please sign in to comment.