Skip to content

Commit

Permalink
fix error message, descriptions
Browse files Browse the repository at this point in the history
  • Loading branch information
prha committed Jan 6, 2025
1 parent ecc6044 commit 21ae854
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -91,8 +91,7 @@ class OpDefinition(NodeDefinition, IHasInternalInit):
code_version (Optional[str]): (Experimental) Version of the code encapsulated by the op. If set,
this is used as a default code version for all outputs.
retry_policy (Optional[RetryPolicy]): The retry policy for this op.
pool (Optional[str]): A string that identifies the concurrency limit group that governs
this op's execution.
pool (Optional[str]): A string that identifies the pool that governs this op's execution.
Examples:
Expand Down Expand Up @@ -613,7 +612,7 @@ def _validate_pool(pool, tags):
tag_concurrency_key = tags.get(GLOBAL_CONCURRENCY_TAG)
if pool and tag_concurrency_key and pool != tag_concurrency_key:
raise DagsterInvalidDefinitionError(
f'Concurrency group "{pool}" that conflicts with the concurrency key tag "{tag_concurrency_key}".'
f'Pool "{pool}" conflicts with the concurrency key tag "{tag_concurrency_key}".'
)

if pool:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -177,7 +177,7 @@ def __new__(
),
tags=check.opt_nullable_mapping_param(tags, "tags", key_type=str, value_type=str),
step_handle=check.opt_inst_param(step_handle, "step_handle", StepHandleTypes),
# stores the concurrency group arg as separate from the concurrency_key property since the
# stores the pool arg as separate from the concurrency_key property since the
# snapshot may have been generated before concurrency_key was added as a separate
# argument
pool=check.opt_str_param(pool, "pool"),
Expand Down

0 comments on commit 21ae854

Please sign in to comment.