Skip to content

Commit 3f9e402

Browse files
OwenKephartDagster Devtools
authored andcommitted
[dagster-databricks] fix issue with op name generation (#20330)
Fixes an issue where if an op name provided, that op name would be used directly for all tasks, leading to name collision issues. Now we just use it as a prefix so names can stay unique. ## Test Plan ## Changelog > If a changelog entry is required, replace this section with the desired entry. > > By default, no changelog entry will be produced for internal PRs. Synced-From-Internal GitOrigin-RevId: 62292313fec1b837930ac537572e2dfe2b935826
1 parent 5e09108 commit 3f9e402

File tree

1 file changed

+2
-3
lines changed
  • python_modules/libraries/dagster-databricks/dagster_databricks/components/databricks_asset_bundle

1 file changed

+2
-3
lines changed

python_modules/libraries/dagster-databricks/dagster_databricks/components/databricks_asset_bundle/component.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -246,11 +246,10 @@ def build_defs(self, context: ComponentLoadContext) -> Definitions:
246246

247247
databricks_assets = []
248248
for task_key, asset_specs in self.asset_specs_by_task_key.items():
249+
op_prefix = self.op.name if self.op and self.op.name else "databricks"
249250

250251
@multi_asset(
251-
name=self.op.name
252-
if self.op and self.op.name
253-
else f"databricks_{task_key}_multi_asset_{component_defs_path_as_python_str}",
252+
name=f"{op_prefix}_{task_key}_multi_asset_{component_defs_path_as_python_str}",
254253
specs=asset_specs,
255254
can_subset=False,
256255
op_tags=self.op.tags if self.op else None,

0 commit comments

Comments
 (0)