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

Flink Unique Job Names #156

Open
wants to merge 8 commits into
base: main
Choose a base branch
from
Open

Conversation

ranchodeluxe
Copy link
Collaborator

Addresses #132

Copy link

codecov bot commented Nov 29, 2023

Codecov Report

All modified and coverable lines are covered by tests ✅

Comparison is base (9667ae6) 95.53% compared to head (b43129e) 95.60%.

Additional details and impacted files
@@            Coverage Diff             @@
##             main     #156      +/-   ##
==========================================
+ Coverage   95.53%   95.60%   +0.06%     
==========================================
  Files          14       14              
  Lines         493      500       +7     
==========================================
+ Hits          471      478       +7     
  Misses         22       22              

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

@ranchodeluxe ranchodeluxe changed the title WIP: Flink Unique Job Names Flink Unique Job Names Nov 30, 2023
@ranchodeluxe ranchodeluxe added the test-flink Add this label to PRs to trigger Dataflow integration test. label Nov 30, 2023
Copy link
Contributor

@moradology moradology left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looks good. One minor consideration but honestly, it is good to go as is

"""
if self.bakery_class == FlinkOperatorBakery:
unique_suffix = "".join(
secrets.choice(string.ascii_letters + string.digits) for _ in range(5)
Copy link
Contributor

@moradology moradology Feb 13, 2024

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Not sure that it matters, but I like random for this kind of thing so that a seed can be used for predictable outputs

@@ -168,6 +169,21 @@ def autogenerate_job_name(self):

return job_name

def add_unique_suffix_to_flink_jobs(self, per_recipe_unique_job_name):
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

In another PR, we should probably go through and figure out which behaviors we can expect runner implementations to sort out so that Bake can be thin and runner independent. It'd be great for it to not know anything at all about implementation details

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
test-flink Add this label to PRs to trigger Dataflow integration test.
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants