Updated metadata and DAG for cohort_daily_statistics (#2970)
This commit is contained in:
Родитель
e962f93ef3
Коммит
361170cb20
|
@ -75,6 +75,7 @@ with DAG(
|
|||
date_partition_parameter="cohort_date",
|
||||
depends_on_past=False,
|
||||
arguments=["--append_table"],
|
||||
parameters=["submission_date:DATE:{{ds}}"],
|
||||
)
|
||||
|
||||
wait_for_telemetry_derived__unified_metrics__v1 = ExternalTaskCompletedSensor(
|
||||
|
|
|
@ -14,8 +14,13 @@ labels:
|
|||
scheduling:
|
||||
dag_name: bqetl_analytics_aggregations
|
||||
date_partition_parameter: cohort_date
|
||||
arguments: ['--append_table']
|
||||
arguments: ["--append_table"]
|
||||
parameters: ["submission_date:DATE:{{ds}}"]
|
||||
bigquery:
|
||||
time_partitioning:
|
||||
field: cohort_date
|
||||
type: day
|
||||
require_partition_filter: true
|
||||
clustering:
|
||||
fields:
|
||||
- attribution_medium
|
||||
|
|
Загрузка…
Ссылка в новой задаче