File tree 2 files changed +6
-4
lines changed
2 files changed +6
-4
lines changed Original file line number Diff line number Diff line change 5
5
// and it wouldn’t reflect when the data was actually dumped from canvas.
6
6
// More info on UDP's batch-ingest DAG process can be found here: https://resources.unizin.org/display/UDP/Batch-ingest+application
7
7
'''
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");
9
9
''',
10
10
"user" :
11
11
'''
Original file line number Diff line number Diff line change @@ -218,7 +218,10 @@ def update_unizin_metadata(self):
218
218
219
219
logger .debug (metadata_sql )
220
220
221
- status += self .util_function (metadata_sql , 'unizin_metadata' )
221
+ try :
222
+ status += self .util_function (metadata_sql , 'unizin_metadata' )
223
+ except Exception as e :
224
+ logger .warn (f"Could not directly access metadata, this is likely just an issue when using synthetic data." )
222
225
223
226
return status
224
227
@@ -650,7 +653,6 @@ def do(self) -> str:
650
653
logger .info (f'Valid locked course IDs: { self .valid_locked_course_ids } ' )
651
654
652
655
# continue cron tasks
653
-
654
656
logger .info ("** term" )
655
657
status += self .update_term ()
656
658
@@ -683,7 +685,7 @@ def do(self) -> str:
683
685
exception_in_run = True
684
686
685
687
logger .info ("** informational" )
686
- # status += self.update_unizin_metadata()
688
+ status += self .update_unizin_metadata ()
687
689
688
690
all_str_course_ids = set (
689
691
str (x ) for x in Course .objects .get_supported_courses ().values_list ('id' , flat = True )
You can’t perform that action at this time.
0 commit comments