@@ -315,9 +315,9 @@ def process_params(lag, day, input_df, signal, params, logger, local=False):
315
315
).resource ('s3' )
316
316
317
317
(wk_mean , wk_var , weekday_params ,
318
- summary_stats , stream , rep_sched , \
318
+ summary_stats , stream , rep_sched , \
319
319
lin_coeff , EVD_max , EVD_min , last_7 , \
320
- STATE_to_fips , fips_pop_table ) = generate_files (params , lag , signal , local = local , s3 = s3 )
320
+ STATE_to_fips , fips_pop_table ) = generate_files (params , lag , signal , local = local , s3 = s3 )
321
321
322
322
input_df .columns = [str (STATE_to_fips [x ]) if x in list (STATES )
323
323
else x for x in input_df .columns ]
@@ -349,10 +349,10 @@ def process_params(lag, day, input_df, signal, params, logger, local=False):
349
349
350
350
global_outlier_list = []
351
351
for df in [weekday_correction , non_daily_df_test , non_ar_df ]:
352
- global_outlier_list .append (outlier_detect (df .T .merge (summary_stats [df .columns ].loc ['median'
353
- , :], left_index = True , right_index = True
354
- ). merge ( summary_stats [df .columns ].loc ['var' , :],
355
- left_index = True , right_index = True )))
352
+ global_outlier_list .append (outlier_detect (df .T .merge (summary_stats [df .columns ].loc [
353
+ 'median' , :], left_index = True , right_index = True ). merge (
354
+ summary_stats [df .columns ].loc ['var' , :],
355
+ left_index = True , right_index = True )))
356
356
357
357
# Apply AR
358
358
@@ -387,14 +387,14 @@ def process_params(lag, day, input_df, signal, params, logger, local=False):
387
387
type_of_outlier = type_of_outlier .merge (stream_individual ,
388
388
left_index = True , right_index = True ,
389
389
how = 'outer' ).merge (stream_group ,
390
- left_index = True , right_index = True ,
391
- how = 'outer' ).merge (evd_ranking ,
392
- left_index = True ,
393
- right_index = True , how = 'outer'
394
- ).merge (df_for_ts ,
395
- left_index = True ,
396
- right_index = True ,
397
- how = 'outer' ).merge (
390
+ left_index = True , right_index = True ,
391
+ how = 'outer' ).merge (evd_ranking ,
392
+ left_index = True ,
393
+ right_index = True , how = 'outer'
394
+ ).merge (df_for_ts ,
395
+ left_index = True ,
396
+ right_index = True ,
397
+ how = 'outer' ).merge (
398
398
ts_streams ,
399
399
left_index = True , right_index = True , how = 'outer' )
400
400
type_of_outlier ['flash' ] = type_of_outlier ['evd_ranking' ]
0 commit comments