even-wei

{% macro generate_dim_dates(schema_name=target.schema, table_name='dim_dates') %}

    {% set create_table_query %}
    CREATE OR REPLACE TABLE {{ schema_name }}.{{ table_name }} AS
    WITH date_spine AS (
        SELECT
            DATEADD(day, seq4(), '1900-01-01') AS date_at
        FROM TABLE(GENERATOR(ROWCOUNT => 55152))
        WHERE date_at <= '2050-12-31'
    )

even-wei

even-wei

even-wei

# default_runtime_name is the default runtime name to use.
- default_runtime_name = "${RUNTIME}"
+ default_runtime_name = "nvidia-container-runtime"

even-wei

import logging as log
import datetime
from datetime import timedelta
import requests
import numpy as np

# The DAG object; we'll need this to instantiate a DAG
from airflow import DAG
from airflow.models import Variable