KubernetesJobOperator
KubernetesJobOperator copied to clipboard
An airflow operator that executes a task in a kubernetes cluster, given a kubernetes yaml configuration or an image refrence.
**Describe the bug** Job can't start with error ``` Traceback (most recent call last): File "/home/airflow/.local/lib/python3.7/site-packages/airflow_kubernetes_job_operator/kubernetes_job_operator.py", line 368, in execute on_kube_api_event=lambda event: self.handle_kube_api_event( File "/home/airflow/.local/lib/python3.7/site-packages/airflow_kubernetes_job_operator/job_runner.py", line 302, in execute_job watchable_kinds...
### Feature description - what is the functionality you are trying to add/what is the problem you are trying to solve? So basically we are facing this issue located in...
Feel free to write here how you use this operator, what was the case you needed it for, and if you can how it was implemented.
When using KubernetesJobOperator in Apache Airflow and encountering issues where Jinja templating for jinja_job_args is treating Airflow time macros as string, shall we provide a mechanism similar to the templates_dict...
Bumps [apache-airflow](https://github.com/apache/airflow) from 1.10.14 to 2.4.3. Release notes Sourced from apache-airflow's releases. Apache Airflow 2.4.3 Bug Fixes Fix double logging with some task logging handler (#27591) Replace FAB url filtering...
## Feature description and background Currently, the Kubernetes operator supports generating XCom output through job output. But as for receiving XCom input, it only provides the most basic approach through...
## Phenomenon When a user submits a job through Airflow, it runs for a while and then encounters the following error: ```markdown [2024-07-19, 12:46:11 CST] {taskinstance.py:1112} DEBUG - dependency 'Previous...