github-actions[bot] opened a new pull request, #75456: URL: https://github.com/apache/airflow/pull/75456
* Java SDK: register the Scala Spark example as task handlers scala_spark_examples.py owns the Dag and declares its three tasks with @task.stub, but the bundle built a DagDef of the same ID, which is the Dag definition path. Register one handler per task ID instead, so one Dag ID is not declared on both sides. * Java SDK: use the default XCom key overloads in the Scala Spark example Client.getXCom and setXCom are @JvmOverloads, so Scala can call them with only the task ID or value and get the return_value key and current Dag. * Java SDK: shorten the Scala Spark bundle doc comment --------- (cherry picked from commit 52237589d0fbfd32117de4cd512eee44a74a46d1) Co-authored-by: Jason(Zhe-You) Liu <[email protected]> -- 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]
