Open gnguyen87 opened 1 week ago
This PR adds more metadata to earthbeam logs. It parses through the task_idof each log to return its log_type.
task_id
log_type
earthbeam_dag.py
log_to_snowflake()
Description & motivation
This PR adds more metadata to earthbeam logs. It parses through the
task_id
of each log to return itslog_type
.PR Merge Priority:
Changes to existing files:
earthbeam_dag.py
: thelog_to_snowflake()
function now has 3 more lines of code to restructure logs.Tests and QC done