Skip to content

Flink Unique Job Names#156

Open
ranchodeluxe wants to merge 8 commits into
mainfrom
gcorradini/flink_unique_names
Open

Flink Unique Job Names#156
ranchodeluxe wants to merge 8 commits into
mainfrom
gcorradini/flink_unique_names

Conversation

@ranchodeluxe
Copy link
Copy Markdown
Collaborator

Addresses #132

@codecov
Copy link
Copy Markdown

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
Copy Markdown
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
Copy Markdown
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


return job_name

def add_unique_suffix_to_flink_jobs(self, per_recipe_unique_job_name):
Copy link
Copy Markdown
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