Coverage for replication_start.py: 67%

1import datetime 

2import os 

3import sys 

4 

5from database import Database 

6from primary import Primary 

7from replication import Replication 

8from secondary import Secondary 

9 

10 

11def main(name, conn_primary, db_primary, conn_secondary, db_secondary, list_schema_excluded): 

12 print(f"START SCRIPT") 

13 print(f"python {name} {conn_primary} {db_primary} {conn_secondary} {db_secondary}") 

14 

15 # Logs settings 

16 today = datetime.datetime.now().strftime("%Y%m%d-%H-%M-%S") 

17 print(f"\n\nStarting script : {name} at {today}\n") 

18 

19 primary = Primary(Database(conn_primary, db_primary), list_schema_excluded) 

20 secondary = Secondary(Database(conn_secondary, db_secondary)) 

21 replication = Replication(primary, secondary) 

22 replication.run(name, today) 

23 

24 

25if __name__ == '__main__': 25 ↛ 27line 25 didn't jump to line 27 because the condition on line 25 was never true

26 # Initialisation of replication 

27 script_name = os.path.basename(__file__) 

28 connection_primary = sys.argv[1] 

29 db_name_primary = sys.argv[2] 

30 connection_secondary = sys.argv[3] 

31 db_name_secondary = sys.argv[4] if len(sys.argv) > 4 else db_name_primary 

32 schema_excluded_list = sys.argv[5] if len(sys.argv) > 5 else None 

33 schema_excluded = schema_excluded_list.split(',') 

34 

35 main(script_name, connection_primary, db_name_primary, connection_secondary, db_name_secondary, schema_excluded)