task decorator parameters

[Lee2532]

I would like to test the example code as below.

from airflow.decorators import dag, task

@task(
        executor_config={
            "KubernetesExecutor": {
                "request_cpu": "1000m",
                "limit_cpu": "1000m",
                "request_memory": "1024Mi",
                "limit_memory": "1024Mi",
                "node_selector": {"eks.amazonaws.com/nodegroup": "other node group name"},
            }
        },
    )
def test(**kwargs):
        print(kwargs)
        

but is only status : queued
it's not woking

To minimize code modification, I want to use only the existing task operator, not kpo, task.kubernetes.

Could you please let me know if it is possible to run on other nodes with only the task operator and if possible, how can I modify it

[enchant3dmango]

Can you add more description? Also, could you provide more snippets of the code or a screenshot of the DAG on the Airflow Webserver?

[enchant3dmango]

If it's a Python task, have you tried using PythonOperator instead? You can pass the executor_config param in PythonOperator.

Ref: baseoperator.py#L351.

[enchant3dmango]

You can also use @python_task decorator.