Skip to content

Commit

Permalink
delete invalid log
Browse files Browse the repository at this point in the history
  • Loading branch information
sangjun-kang committed Jan 9, 2024
1 parent 680c90b commit 6a30fdf
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions skyplane/gateway/operators/gateway_operator.py
Original file line number Diff line number Diff line change
Expand Up @@ -389,15 +389,14 @@ def socket_connection():
print(f"[sender-{self.worker_id}]:{chunk_id} error sending chunk {e}")
retry_count += 1
if retry_count < max_retries:
print(f"SCP DEV - Retrying (attempt {retry_count} of {max_retries})...")
# 이 위치에 에러 파일 만들기
with open(f"/skyplane/header.to_socket_{retry_count}_{dst_host}_error.txt", "w") as f:
f.write(str(e))
# print(f"SCP DEV - Retrying (attempt {retry_count} of {max_retries})...")
# with open(f"/skyplane/header.to_socket_{retry_count}_{dst_host}_error.txt", "w") as f:
# f.write(str(e))
time.sleep(0.5)
socket_connection()
sock = self.destination_sockets[dst_host]
else:
print(f"SCP DEV - Max retries ({max_retries}) reached. Giving up.")
# print(f"SCP DEV - Max retries ({max_retries}) reached. Giving up.")
raise e
else:
break
Expand Down

0 comments on commit 6a30fdf

Please sign in to comment.