value = dlcutils.widgets.get('param_name')

# Obtain parameter values
dt = dlcutils.widgets.get('dp_data_dt')
print(dt)
# Output: 2026-06-11

# If numeric values are required, explicitly convert them.
batch_size = int(dlcutils.widgets.get('batch_size'))

col_a_value = dlcutils.widgets.get('task_param')
print(col_a_value)
# Output: The value of col_a in the first row of the upstream SQL result.

${param_name}

SELECT *
FROM my_table
WHERE dt = '${dp_data_dt}';
-- Replaced at runtime with: WHERE dt = '2026-06-11'

USE ${target_db};
SELECT COUNT(*) FROM orders;
-- Replaced at runtime with: USE my_database;

SELECT *
FROM ${target_db}.${target_table}
WHERE dt = '${dp_data_dt}'
  AND env = '${env}';

# Workflow parameter definition
dp_data_dt = {{workflow.start_time.iso_date}}

-- Referencing in SQL (Recommended)
WHERE dt = '${dp_data_dt}'

-- Writing built-in parameters directly in code is not recommended.

# Referencing in Notebook (Recommended)
dt = dlcutils.widgets.get('dp_data_dt')

trigger_date = {{workflow.trigger.time.iso_date}}

-- Workflow parameter defined: trigger_date = {{workflow.trigger.time.iso_date}}.
-- Use the DATE_SUB function to subtract 1 day from the trigger date as the partition time.
SELECT *
FROM dw.user_daily
WHERE dt = DATE_SUB('${trigger_date}', INTERVAL 1 DAY);
-- If the trigger time is 2026-06-12, it is equivalent to: WHERE dt = '2026-06-11'.

WHERE dt = DATE_ADD('${trigger_date}', INTERVAL -1 DAY);

from datetime import datetime, timedelta

# Obtain the trigger date from the workflow parameters.
trigger_date = dlcutils.widgets.get('trigger_date')
# Example of the trigger_date value: '2026-06-12'.

# Calculate the previous day as the partition time.
dt_obj = datetime.strptime(trigger_date, '%Y-%m-%d')
partition_date = (dt_obj - timedelta(days=1)).strftime('%Y-%m-%d')
print(partition_date)
# Output: 2026-06-11.

# Use partition_date for subsequent data reads and writes.
spark.sql(f"SELECT * FROM dw.user_daily WHERE dt = '{partition_date}'")

-- String type fields: Add quotes.
WHERE dt = '${dp_data_dt}'

-- Numeric type fields: Do not add quotes (the parameter value itself is a numeric string).
WHERE id = ${target_id}

# String parameters
env = dlcutils.widgets.get('env')

# When numeric values are required
batch_size = int(dlcutils.widgets.get('batch_size'))
threshold = float(dlcutils.widgets.get('threshold'))

import os

# In Notebook, you can try to obtain the parameter first, and use the default value if it cannot be obtained.
dt = dlcutils.widgets.get('dp_data_dt')
if not dt:
    dt = '2026-06-11'  # Default value for development