Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

ckan_api_load_multiple_steps is not found in dags folder #135

Open
Alqatf opened this issue Mar 7, 2024 · 0 comments
Open

ckan_api_load_multiple_steps is not found in dags folder #135

Alqatf opened this issue Mar 7, 2024 · 0 comments

Comments

@Alqatf
Copy link

Alqatf commented Mar 7, 2024

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.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant