Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Core feature] Make execution_id and execution_domain available for plugins #6308

Open
2 tasks done
rambrus opened this issue Mar 5, 2025 · 0 comments
Open
2 tasks done
Labels
enhancement New feature or request untriaged This issues has not yet been looked at by the Maintainers

Comments

@rambrus
Copy link

rambrus commented Mar 5, 2025

Motivation: Why do you think this is important?

BACKGROUND

https://flyte-org.slack.com/archives/CP2HDHKE1/p1741181647724639

ISSUE

We are trying to fetch Flyte execution domain in a Spark task running in Databricks using the Fyte Databricks plugin.

We tried 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 in case of Databricks plugin. It would be nice to pass this info in the API so that we can access it in tasks.

Goal: What should the final outcome look like, ideally?

We are able to fetch execution domain in tasks.

Describe alternatives you've considered

Pass the domain as workflow input param.

Propose: Link/Inline OR Additional context

No response

Are you sure this issue hasn't been raised already?

  • Yes

Have you read the Code of Conduct?

  • Yes
@rambrus rambrus added enhancement New feature or request untriaged This issues has not yet been looked at by the Maintainers labels Mar 5, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request untriaged This issues has not yet been looked at by the Maintainers
Projects
Status: Backlog
Development

No branches or pull requests

1 participant