11
11
12
12
13
13
def get_argument_parser ():
14
- """Define command line arguments."""
14
+ """Define command line arguments."""
15
15
16
- parser = argparse .ArgumentParser ()
17
- parser .add_argument (
18
- '--deletion_dir' ,
19
- help = 'directory where deletion CSVs are stored' )
20
- parser .add_argument (
21
- '--log_file' ,
22
- help = "filename for log output (defaults to stdout)" )
23
- return parser
16
+ parser = argparse .ArgumentParser ()
17
+ parser .add_argument (
18
+ '--deletion_dir' ,
19
+ help = 'directory where deletion CSVs are stored' )
20
+ parser .add_argument (
21
+ '--log_file' ,
22
+ help = "filename for log output (defaults to stdout)" )
23
+ return parser
24
24
25
25
def handle_file (deletion_file , database ):
26
26
logger .info ("Deleting from csv file" , filename = deletion_file )
@@ -39,23 +39,23 @@ def handle_file(deletion_file, database):
39
39
return 0
40
40
41
41
def main (args ):
42
- """Delete rows from covidcast."""
42
+ """Delete rows from covidcast."""
43
43
44
- logger = get_structured_logger ("csv_deletion" , filename = args .log_file )
45
- start_time = time .time ()
46
- database = Database ()
47
- database .connect ()
48
- all_n = 0
44
+ logger = get_structured_logger ("csv_deletion" , filename = args .log_file )
45
+ start_time = time .time ()
46
+ database = Database ()
47
+ database .connect ()
48
+ all_n = 0
49
49
50
- try :
51
- for deletion_file in sorted (glob .glob (os .path .join (args .deletion_dir , '*.csv' ))):
52
- all_n += handle_file (deletion_file )
53
- finally :
54
- database .disconnect (True )
50
+ try :
51
+ for deletion_file in sorted (glob .glob (os .path .join (args .deletion_dir , '*.csv' ))):
52
+ all_n += handle_file (deletion_file )
53
+ finally :
54
+ database .disconnect (True )
55
55
56
- logger .info (
57
- "Deleted CSVs from database" ,
58
- total_runtime_in_seconds = round (time .time () - start_time , 2 ), row_count = all_n )
56
+ logger .info (
57
+ "Deleted CSVs from database" ,
58
+ total_runtime_in_seconds = round (time .time () - start_time , 2 ), row_count = all_n )
59
59
60
60
if __name__ == '__main__' :
61
- main (get_argument_parser ().parse_args ())
61
+ main (get_argument_parser ().parse_args ())
0 commit comments