diff --git a/python_modules/dagster/dagster/_core/definitions/declarative_automation/operands/operands.py b/python_modules/dagster/dagster/_core/definitions/declarative_automation/operands/operands.py index d4eb5148398f1..d4fe5dd2ea34f 100644 --- a/python_modules/dagster/dagster/_core/definitions/declarative_automation/operands/operands.py +++ b/python_modules/dagster/dagster/_core/definitions/declarative_automation/operands/operands.py @@ -71,7 +71,7 @@ async def compute_subset(self, context: AutomationContext) -> EntitySubset: class RunInProgressAutomationCondition(SubsetAutomationCondition): @property def name(self) -> str: - return "execution_in_progress" + return "run_in_progress" async def compute_subset(self, context: AutomationContext) -> EntitySubset: return await context.asset_graph_view.compute_run_in_progress_subset(key=context.key) diff --git a/python_modules/dagster/dagster_tests/definitions_tests/declarative_automation_tests/automation_condition_tests/fundamentals/test_result_value_hash.py b/python_modules/dagster/dagster_tests/definitions_tests/declarative_automation_tests/automation_condition_tests/fundamentals/test_result_value_hash.py index d6c13b875a9f0..eaf1896d07008 100644 --- a/python_modules/dagster/dagster_tests/definitions_tests/declarative_automation_tests/automation_condition_tests/fundamentals/test_result_value_hash.py +++ b/python_modules/dagster/dagster_tests/definitions_tests/declarative_automation_tests/automation_condition_tests/fundamentals/test_result_value_hash.py @@ -39,11 +39,11 @@ ("dd74c7cfe19d869931ea4aad9ee10127", SC.on_cron("0 * * * *"), two_parents, False), ("861f8e40d4624d49c4ebdd034c8e1e84", SC.on_cron("0 * * * *"), two_parents_daily, False), # same as above - ("9b4c0a55b5fbea860f72ecc9d7a27e0e", SC.eager(), one_parent, False), - ("6925b7770eb2122048e4f50aa0a3303f", SC.eager(), one_parent, True), - ("45c2493882264dd06bee6c9abffabf3e", SC.eager(), one_parent_daily, False), - ("81132ce4972e8ac8d8be1a0e468637c0", SC.eager(), two_parents, False), - ("724d21fef8f7404f1e26b40ddeab711d", SC.eager(), two_parents_daily, False), + ("f8237121a2848d3bef57376d2c3908a1", SC.eager(), one_parent, False), + ("814fbbf023768be85417e19dfc3ed446", SC.eager(), one_parent, True), + ("771796e08a6d705df7cb25f86debb109", SC.eager(), one_parent_daily, False), + ("60461372601abf65f9a290f8287d20c2", SC.eager(), two_parents, False), + ("c955823e087245ecc3a4dd1e42344984", SC.eager(), two_parents_daily, False), # missing condition is invariant to changes other than partitions def changes ("6d7809c4949e3d812d7eddfb1b60d529", SC.missing(), one_parent, False), ("6d7809c4949e3d812d7eddfb1b60d529", SC.missing(), one_parent, True),