Skip to content

Commit

Permalink
linting errors
Browse files Browse the repository at this point in the history
  • Loading branch information
ffalor committed Mar 14, 2024
1 parent 69fa2f3 commit 3457522
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 7 deletions.
9 changes: 3 additions & 6 deletions falcon_data_replicator.py
Original file line number Diff line number Diff line change
Expand Up @@ -297,12 +297,9 @@ def consume_data_replicator(s3_bkt, s3_cs_bkt, log: logging.Logger):
byte_cnt += res[1]
received = res[2]
total_event_count += res[3]['total_event_count']
if max_total_download_time_sec < res[3]['total_download_time_sec']:
max_total_download_time_sec = res[3]['total_download_time_sec']
if max_total_transform_time_sec < res[3]['total_transform_time_sec']:
max_total_transform_time_sec = res[3]['total_transform_time_sec']
if max_total_upload_time_sec < res[3]['total_upload_time_sec']:
max_total_upload_time_sec = res[3]['total_upload_time_sec']
max_total_download_time_sec = max(max_total_download_time_sec, res[3]['total_download_time_sec'])
max_total_transform_time_sec = max(max_total_transform_time_sec, res[3]['total_transform_time_sec'])
max_total_upload_time_sec = max(max_total_upload_time_sec, res[3]['total_upload_time_sec'])
m_tot_time_sec = max_total_download_time_sec + \
max_total_transform_time_sec + max_total_upload_time_sec
max_total_time_sec = max(max_total_time_sec, m_tot_time_sec)
Expand Down
2 changes: 1 addition & 1 deletion standalone/falcon_data_replicator.py
Original file line number Diff line number Diff line change
Expand Up @@ -169,7 +169,7 @@ def download_message_files(msg):
logger.info(
f"Skipping {msg_output_path} to prevent writes outside of output path: {FDR.output_path}"
)
continue
continue
# Ensure directory exists at output path
if not os.path.exists(msg_output_path):
# Create it if it doesn't
Expand Down

0 comments on commit 3457522

Please sign in to comment.