diff --git a/ProductionTools/oracle_db_disaster_recovery/oracle_sync_transferred_files_to_lbs_and_streams.py b/ProductionTools/oracle_db_disaster_recovery/oracle_sync_transferred_files_to_lbs_and_streams.py index 849969456face02eda5ce5bb30ee5baaca173a5f..f81573fb88a3ed6065487778fb3cf48973e15cbe 100755 --- a/ProductionTools/oracle_db_disaster_recovery/oracle_sync_transferred_files_to_lbs_and_streams.py +++ b/ProductionTools/oracle_db_disaster_recovery/oracle_sync_transferred_files_to_lbs_and_streams.py @@ -25,7 +25,7 @@ class MockParsed: self.lbnr = lbnr self.streamtype = streamtype self.streamname = streamname - + def AppId(self): return self.sfoid def RunNr(self): return self.runnr def LBNr(self): return self.lbnr @@ -75,7 +75,7 @@ def oracle_sync_transferred_files_to_lbs_and_streams(oradb_url, else: if reportf: reportf.write(f'would have marked LB({run_number},' f'{sfoid},{lbnr},{streamtype},{streamname}) transferred\n') - + updated_streams = 0 non_transferred_streams = oradb.db.curs.execute("""select SFOID, STREAMTYPE, STREAM, STATE from SFO_TZ_RUN @@ -103,10 +103,10 @@ def oracle_sync_transferred_files_to_lbs_and_streams(oradb_url, else: if reportf: reportf.write(f'would have marked stream({run_number},' f'{sfoid},{streamtype},{streamname}) transferred\n') - + oradb.db.orcl.close() - if report: + if reportf: reportf.write('---- end of marking LBs and streams transferred\n') reportf.close() if verbose: