AttributeError While Evaluating Automation Condition

[bolinzzz]

Hi team! I am on Dagster 1.8.10 and attempting to migrate from AutoMaterializePolicy to AutomationCondition.

I noticed the Automation/default_automation_condition_sensor is failing with the following error:

Exception: Error while evaluating conditions for databricks/data_warehouse_raw/account_fund_deposit_records
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_daemon/asset_daemon.py", line 876, in _process_auto_materialize_tick_generator
    yield from self._evaluate_auto_materialize_tick(
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_daemon/asset_daemon.py", line 962, in _evaluate_auto_materialize_tick
    ).evaluate()
      ^^^^^^^^^^
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/definitions/automation_tick_evaluation_context.py", line 181, in evaluate
    results, entity_subsets = self._evaluator.evaluate()
                              ^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/definitions/declarative_automation/automation_condition_evaluator.py", line 131, in evaluate
    raise Exception(
The above exception was caused by the following exception:
AttributeError: 'bool' object has no attribute 'is_empty'
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/definitions/declarative_automation/automation_condition_evaluator.py", line 129, in evaluate
    self.evaluate_entity(entity_key)
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/definitions/declarative_automation/automation_condition_evaluator.py", line 153, in evaluate_entity
    result = context.condition.evaluate(context)
             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/definitions/declarative_automation/operators/dep_operators.py", line 162, in evaluate
    dep_result = dep_condition.evaluate(
                 ^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/definitions/declarative_automation/operators/dep_operators.py", line 47, in evaluate
    dep_result = self.operand.evaluate(dep_context)
                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/definitions/declarative_automation/operators/boolean_operators.py", line 45, in evaluate
    child_result = child.evaluate(child_context)
                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/definitions/declarative_automation/operators/since_operator.py", line 48, in evaluate
    reset_result = self.reset_condition.evaluate(reset_context)
                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/definitions/declarative_automation/operators/boolean_operators.py", line 95, in evaluate
    true_subset = true_subset.compute_union(child_result.true_subset)
                  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/asset_graph_view/entity_subset.py", line 85, in compute_union
    return self._oper(other, operator.or_)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/asset_graph_view/entity_subset.py", line 70, in _oper
    value = oper(self.get_internal_value(), other.get_internal_value())
            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/definitions/time_window_partitions.py", line 2155, in __or__
    return _attempt_coerce_to_time_window_subset(self) | _attempt_coerce_to_time_window_subset(
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/definitions/time_window_partitions.py", line 2397, in __or__
    return super().__or__(other)
           ^^^^^^^^^^^^^^^^^^^^^
  File "/opt/dagster/dagster_home/.venv/lib/python3.11/site-packages/dagster/_core/definitions/partition.py", line 980, in __or__
    if self is other or other.is_empty:
                        ^^^^^^^^^^^^^^

For context, databricks/data_warehouse_raw/account_fund_deposit_records has five upstream dependencies. The AutomationCondition I have defined is as such:

wait_for_all_parents_policy = AutomationCondition.all_deps_match(
            AutomationCondition.eager()
        ).with_label("eager but will wait for all upstream dependencies")

I want the asset to wait for all upstream to be updated before running.

Not sure what is causing the error, could you provide some assistance? Is this caused by one of the code location not being connected (the UAE one)?

Here's the lineage graph:

AutomationCondition evaluation is failing:

[bolinzzz]

More details that might be relevant. The upstream dependencies of the asset being evaluated used to be non partitioned, which were switch to become partitioned lately.

[bolinzzz]

I believe this caused the failure. After removing and re-adding the asset, everything is running fine now