add source schema to show_status

the4thdoctor · Nov 25, 2017 · d7b923c · d7b923c
1 parent 4ed58a8
commit d7b923c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/pg_chameleon/lib/global_lib.py b/pg_chameleon/lib/global_lib.py
@@ -516,7 +516,7 @@ def show_status(self):
 			list the replica status using the configuration files and the replica catalogue
 		"""
 		source_status=self.pg_eng.get_status()
-		tab_headers = ['Config file',  'Destination schema',  'Status' ,  'Read lag',  'Last read',  'Replay lag' , 'Last replay']
+		tab_headers = ['Config file',  'Source schema', 'Destination schema',  'Status' ,  'Read lag',  'Last read',  'Replay lag' , 'Last replay']
 		tab_body = []
 
 		for status in source_status:
@@ -527,7 +527,8 @@ def show_status(self):
 			last_read = status[4]
 			replay_lag = status[5]
 			last_replay = status[6]
-			tab_row = [source_name, dest_schema, source_status, read_lag, last_read,  replay_lag, last_replay]
+			source_schema = status[7]
+			tab_row = [source_name, source_schema,  dest_schema, source_status, read_lag, last_read,  replay_lag, last_replay]
 			tab_body.append(tab_row)
 		print(tabulate(tab_body, headers=tab_headers))
 

diff --git a/pg_chameleon/lib/pg_lib.py b/pg_chameleon/lib/pg_lib.py
@@ -798,7 +798,8 @@ def get_status(self):
 				date_trunc('seconds',now())-ts_last_received lag,
 				ts_last_received,
 				ts_last_received-ts_last_replay,
-				ts_last_replay
+				ts_last_replay,
+				t_source_schema
 			FROM 
 				sch_chameleon.t_sources
 			ORDER BY