Lee-W commented on issue #31743:
URL: https://github.com/apache/airflow/issues/31743#issuecomment-1598305610
I format the error message a bit for better understanding.
```
Traceback (most recent call last):
File
"/home/airflow/.local/lib/python3.7/site-packages/airflow/utils/module_loading.py",
line 39,
in import_string
return getattr(module, class_name)
AttributeError: module 'my_file_name' has no attribute 'listen_function'
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File
"/home/airflow/.local/lib/python3.7/site-packages/airflow/jobs/triggerer_job_runner.py",
line 529,
in cleanup_finished_triggers
result = details["task"].result()
File
"/home/airflow/.local/lib/python3.7/site-packages/airflow/jobs/triggerer_job_runner.py",
line 607,
in run_trigger
async for event in trigger.run():
File
"/home/airflow/.local/lib/python3.7/site-packages/airflow/providers/apache/kafka/triggers/await_message.py",
line 99
in run
processing_call = import_string(self.apply_function)
File
"/home/airflow/.local/lib/python3.7/site-packages/airflow/utils/module_loading.py",
line 41,
in import_string
raise ImportError(f'Module "{module_path}" does not define a
"{class_name}" attribute/class')
ImportError: Module "my_file_name" does not define a "await_function"
attribute/class
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
