email changes 4 (#78)

* Grant Pipeline-New GARD Mapping Process * Change get_node_counts * Removal of leftover merge text * More merge text removal * gfkg and pakg bug fixes * New CTKG pipeline * aact edit * changes for e alert * email alert chges 2 * email changes 3 * email changes 4 --------- Co-authored-by: Devon Joseph Leadman <[email protected]>
ncats · Oct 23, 2024 · 1d596f4 · 1d596f4
1 parent 508a587
commit 1d596f4
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 7 deletions.
diff --git a/start_prod.py b/start_prod.py
@@ -10,8 +10,6 @@
 from subprocess import *
 from time import sleep
 import argparse
-import detect_transfer
-import seed_cluster
 from RDAS_MEMGRAPH_APP.Alert import Alert
 from RDAS_MEMGRAPH_APP.Transfer import Transfer
 from datetime import datetime
@@ -30,9 +28,7 @@
         print('checking for update...')
         # Detect new dumps in the production server
         transfer_detection,last_updates = transfer_module.detect(sysvars.transfer_path)
-        approval_detection,last_updates_approval = transfer_module.detect(sysvars.approved_path)
-        new_dumps = [k for (k,v) in transfer_detection.items() if v]
-        new_dumps_approval = [k for (k,v) in approval_detection.items() if v]
+        new_dumps = transfer_detection
 
         # Sets the current db files last transfer date to today so it doesnt load and send emails upon script starting
         if init:

diff --git a/start_test.py b/start_test.py
@@ -26,10 +26,15 @@
 recip = sysvars.contacts['test']
 today_str = datetime.today().strftime('%m/%d/%y')
 
+# INIT
+transfer_detection,lastupdates = transfer_module.detect(sysvars.transfer_path)
+transfer_detection,lastupdates = transfer_module.detect(sysvars.approved_path)
+
 while True:
     # Detects all new dump files in the transfer folder of the TEST server
     transfer_detection,lastupdates = transfer_module.detect(sysvars.transfer_path)
-    new_dumps = transfer_detection[0]
+    new_dumps = transfer_detection
+
     for db_name in new_dumps:
         transfer_module.seed(db_name,sysvars.transfer_path)
         transfer_module.seed(db_name,sysvars.transfer_path)
@@ -71,7 +76,8 @@
 
     # Detects if a new dump file was loaded into the approved folder
     transfer_detection,lastupdates = transfer_module.detect(sysvars.approved_path)
-    new_dumps = transfer_detection[0]
+    new_dumps = transfer_detection
+
     print(new_dumps)
 
     for db_name in new_dumps: