Skip to content

Commit

Permalink
Remove integrity_sync data in stable phase
Browse files Browse the repository at this point in the history
  • Loading branch information
Selutario committed Jun 14, 2022
1 parent daeda1e commit 7291d98
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -127,7 +127,7 @@ def _calculate_all_df_stats(self, dfs_dict):
for phase in [self.SETUP_PHASE, self.STABLE_PHASE]:
for file_name, file_df in files.items():
trimmed_df = self._trim_dataframe(file_df, phase, setup_datetime)
if len(trimmed_df):
if len(trimmed_df) and not (phase == self.STABLE_PHASE and file_name == 'integrity_sync'):
result[phase][file_name][node] = self._calculate_stats(trimmed_df)

return result
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -98,6 +98,6 @@ resources:
mean: 197162 # (197 MB)
reg_cof: 209.6
workers:
max: 201480 # (201 MB)
max: 256000 # (250 MB)
mean: 145000 # (145 MB)
reg_cof: 260

0 comments on commit 7291d98

Please sign in to comment.