Fix pytype from #619

skyplane-project · Oct 18, 2022 · 9c50d7e · 9c50d7e
1 parent 2b3a6a1
commit 9c50d7e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/skyplane/replicate/replicator_client.py b/skyplane/replicate/replicator_client.py
@@ -576,6 +576,7 @@ def monitor_transfer(
         sink_regions = set(s.region for s in sinks)
 
         (self.transfer_dir / "job.pkl").write_bytes(pickle.dumps(job))
+        error = False
         try:
             with Progress(
                 SpinnerColumn(),
@@ -588,7 +589,6 @@ def monitor_transfer(
             ) as progress:
                 copy_task = progress.add_task("", total=total_bytes)
                 with Timer() as t:
-                    error = False
                     while True:
                         # refresh shutdown status by running noop
                         do_parallel(lambda i: i.run_command("echo 1"), self.bound_nodes.values(), n=-1)