[GitHub] [airflow] tirkarthi commented on issue #29561: CeleryKubernetesExecutor @task(queue="kubernetes")  not work

2023-02-20 Thread via GitHub
tirkarthi commented on issue #29561: URL: https://github.com/apache/airflow/issues/29561#issuecomment-1436569555 You're welcome @takersk -- 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 speci

[GitHub] [airflow] tirkarthi commented on issue #29561: CeleryKubernetesExecutor @task(queue="kubernetes")  not work

2023-02-19 Thread via GitHub
tirkarthi commented on issue #29561: URL: https://github.com/apache/airflow/issues/29561#issuecomment-1436385102 Values returned by tasks should be JSON serializable. Please see comments https://github.com/apache/airflow/issues/28492#issuecomment-1359564322 and https://github.com/apache/air

[GitHub] [airflow] tirkarthi commented on issue #29561: CeleryKubernetesExecutor @task(queue="kubernetes")  not work

2023-02-19 Thread via GitHub
tirkarthi commented on issue #29561: URL: https://github.com/apache/airflow/issues/29561#issuecomment-1436341424 `example_task_kubernetes` is the function name decorated by `@task` . You also seem to be passing the same value as task_id to `exec_trino_query_pod` where if you are trying to c