Skip to content

Commit 8d229a6

Browse files
committed
Added back in metadata, added try/except if it fails
1 parent 64d5b7b commit 8d229a6

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

config/cron_udp.hjson

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
// and it wouldn’t reflect when the data was actually dumped from canvas.
66
// More info on UDP's batch-ingest DAG process can be found here: https://resources.unizin.org/display/UDP/Batch-ingest+application
77
'''
8-
SELECT * FROM EXTERNAL_QUERY("context_store", "select 'canvasdatadate' as pkey, min(dag_run) as pvalue from report.publish_info pi2");
8+
SELECT * FROM EXTERNAL_QUERY("us.context_store", "select 'canvasdatadate' as pkey, min(dag_run) as pvalue from report.publish_info pi2");
99
''',
1010
"user" :
1111
'''

dashboard/cron.py

+5-1
Original file line numberDiff line numberDiff line change
@@ -226,7 +226,10 @@ def update_unizin_metadata(self):
226226

227227
logger.debug(metadata_sql)
228228

229-
status += self.util_function(metadata_sql, 'unizin_metadata')
229+
try:
230+
status += self.util_function(metadata_sql, 'unizin_metadata')
231+
except Exception as e:
232+
logger.warn(f"Could not directly access metadata, this is likely just an issue when using synthetic data.")
230233

231234
return status
232235

@@ -652,6 +655,7 @@ def do(self) -> str:
652655

653656
# continue cron tasks
654657

658+
logger.info("** term")
655659
status += self.update_term()
656660

657661
exception_in_run = False

0 commit comments

Comments
 (0)