def METHOD_NAME(cmd=None, dbt_args=None, **context):
    """This function will execute the KubernetesPodOperator as an Airflow task"""
    dbt_full_args = get_dbt_full_args(dbt_args)
    execution_date = dbt_args['execution_date']
    # The pod id should be unique for each execution date
    pod_id = 'dbt_cli_{}_{}'.format(cmd, execution_date)
    KubernetesPodOperator(
        task_id=pod_id,
        name=pod_id,
        image_pull_policy='Always',
        arguments=[cmd] + dbt_full_args,
        namespace='default',
        get_logs=True,  # Capture logs from the pod
        log_events_on_failure=True,  # Capture and log events in case of pod failure
        is_delete_operator_pod=True, # To clean up the pod after runs
        image=IMAGE,
        secrets=[secret_volume]  # Set Kubernetes secret reference to dbt's service account JSON
    ).execute(context)