uranusjr commented on issue #67683: URL: https://github.com/apache/airflow/issues/67683#issuecomment-4700158487
I thought about this a bit. Since it doesn’t really make much sense to expose this to Java (any language except Kotlin really), it’s probably better to split this into a separate package, or even a separate artifact. Not sure. Probably better than to prefix everything (AsyncClient AsyncTask and so on. I’m not exactly sure what the best approach here is tbh.) Either way, we should have 1. An async equivalent of `org.apache.airflow.sdk.execution.Client`. 1. An async equivalent of `org.apache.airflow.sdk.Client`. 1. An async Task interface that requires `suspend fun execute(Context, Client)` where `Client` is the async version (`Context` should be the same). 1. Extend `Dag.add_task()` to also accept an async Task, and `TaskRunner` to handle it. 1. Extend `@Builder.Task` to be able to convert an annotated `suspend fun` to an async Task. -- 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]
