-
Notifications
You must be signed in to change notification settings - Fork 7
Open
Description
I have implemented the following:
(base) majjedfmci@k8sworker2:~$ airflow dags trigger ckan_api_load_multiple_steps --conf='{ "resource": {
"path": "/home/majjedfmci/Downloads/MAJJED.csv",
"format": "txt",
"ckan_resource_id": "e7078210-79ff-4514-8372-aaa88d1f8ddb",
"schema": {
"fields": [
{
'id': 'Industry', 'type': 'text',
"format": "default"
}
]
}
},
"ckan_config": {
"api_key": "J0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJqdGkiOiJXd1k3UGZRODRxcXo5NktMVU1ZWUNNNVExdmREUFlmc3VEZTZzbm44dUtrIiwiaWF0IjoxNzA5NjcwOTE1fQ.I9oE5ScEGhWacQwcxtrXADrkhhsVa95mGtXzAoBIBUI",
"site_url": "http://127.0.0.1:5000",
}
}'
/home/majjedfmci/anaconda3/lib/python3.11/site-packages/airflow/utils/dot_renderer.py:28 UserWarning: Could not import graphviz. Rendering graph to the graphical format will not be possible.
[2024-03-07T19:01:53.183+0000] {init.py:42} INFO - Loaded API auth backend: airflow.api.auth.backend.session
Traceback (most recent call last):
File "/home/majjedfmci/anaconda3/bin/airflow", line 8, in
sys.exit(main())
^^^^^^
File "/home/majjedfmci/anaconda3/lib/python3.11/site-packages/airflow/main.py", line 57, in main
args.func(args)
File "/home/majjedfmci/anaconda3/lib/python3.11/site-packages/airflow/cli/cli_config.py", line 49, in command
return func(*args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^
File "/home/majjedfmci/anaconda3/lib/python3.11/site-packages/airflow/utils/cli.py", line 114, in wrapper
return f(*args, **kwargs)
^^^^^^^^^^^^^^^^^^
File "/home/majjedfmci/anaconda3/lib/python3.11/site-packages/airflow/utils/providers_configuration_loader.py", line 55, in wrapped_function
return func(*args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^
File "/home/majjedfmci/anaconda3/lib/python3.11/site-packages/airflow/cli/commands/dag_command.py", line 164, in dag_trigger
message = api_client.trigger_dag(
^^^^^^^^^^^^^^^^^^^^^^^
File "/home/majjedfmci/anaconda3/lib/python3.11/site-packages/airflow/api/client/local_client.py", line 34, in trigger_dag
dag_run = trigger_dag.trigger_dag(
^^^^^^^^^^^^^^^^^^^^^^^^
File "/home/majjedfmci/anaconda3/lib/python3.11/site-packages/airflow/api/common/trigger_dag.py", line 122, in trigger_dag
raise DagNotFound(f"Dag id {dag_id} not found in DagModel")
airflow.exceptions.DagNotFound: Dag id ckan_api_load_multiple_steps not found in DagModel
As you see above that ckan_api_load_multiple_steps is not found. Can someone help me how to handle this issue. Thanks in advance.
Metadata
Metadata
Assignees
Labels
No labels