Hi team, We are trying to fetch execution domain in Spark task running on Kubernetes. Trying to use the same method that works well in Python tasks running on K8s (flytekit.current_context().execution_id.domain) Unfortunately, this approach does not work. Is there a way to fetch Flyte domain in case of Spark tasks running on Databricks? I guess we need to pass it as an execution param if the context does not hold this info.

Are you using agents?

no, we still use plugins

Then it’s probably not passed in the api

all right, will do, thanks!

@freezing-airport-6809 is the list of env vars needed for this documented anywhere?

It’s in the backend - it’s really simple to add

@microscopic-minister-38807, as Ketan mentioned above, this should be easy to add. The list of env vars currently injected in tasks is around here.