dstandish commented on code in PR #25175:
URL: https://github.com/apache/airflow/pull/25175#discussion_r926861103
##
airflow/www/views.py:
##
@@ -5330,6 +5330,14 @@ def _calculate_graph(self):
@staticmethod
def _node_dict(node_id, label, node_class):
+def tru
dstandish commented on code in PR #25175:
URL: https://github.com/apache/airflow/pull/25175#discussion_r926843361
##
airflow/www/views.py:
##
@@ -5330,6 +5330,14 @@ def _calculate_graph(self):
@staticmethod
def _node_dict(node_id, label, node_class):
+def tru
dstandish commented on code in PR #25175:
URL: https://github.com/apache/airflow/pull/25175#discussion_r926809274
##
airflow/www/views.py:
##
@@ -5330,6 +5330,14 @@ def _calculate_graph(self):
@staticmethod
def _node_dict(node_id, label, node_class):
+def tru
dstandish commented on code in PR #25175:
URL: https://github.com/apache/airflow/pull/25175#discussion_r925771460
##
airflow/serialization/serialized_objects.py:
##
@@ -839,7 +882,21 @@ def deserialize_operator(cls, encoded_op: Dict[str, Any])
-> Operator:
@classmethod
dstandish commented on code in PR #25175:
URL: https://github.com/apache/airflow/pull/25175#discussion_r925768619
##
airflow/serialization/serialized_objects.py:
##
@@ -839,7 +882,21 @@ def deserialize_operator(cls, encoded_op: Dict[str, Any])
-> Operator:
@classmethod
dstandish commented on code in PR #25175:
URL: https://github.com/apache/airflow/pull/25175#discussion_r925765811
##
airflow/models/dagbag.py:
##
@@ -623,11 +623,12 @@ def _serialize_dag_capturing_errors(dag, session):
)
self.log.debug("Calling
dstandish commented on code in PR #25175:
URL: https://github.com/apache/airflow/pull/25175#discussion_r925763651
##
airflow/models/dagbag.py:
##
@@ -623,11 +623,12 @@ def _serialize_dag_capturing_errors(dag, session):
)
self.log.debug("Calling