bbovenzi commented on PR #24284:
URL: https://github.com/apache/airflow/pull/24284#issuecomment-1154204558
> Stack trace for that?
>
> I didn't test with running DAGs. Oops! (Good thing we can add tests now)
```
TypeError
TypeError: '<' not supported between instances of 'NoneType' and 'NoneType'
Traceback (most recent call last)
File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 2464, in
__call__
def __call__(self, environ, start_response):
"""The WSGI server calls the Flask application object as the
WSGI application. This calls :meth:`wsgi_app` which can be
wrapped to applying middleware."""
return self.wsgi_app(environ, start_response)
def __repr__(self):
return "<%s %r>" % (self.__class__.__name__, self.name)
File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 2450, in
wsgi_app
try:
ctx.push()
response = self.full_dispatch_request()
except Exception as e:
error = e
response = self.handle_exception(e)
except: # noqa: B001
error = sys.exc_info()[1]
raise
return response(environ, start_response)
finally:
File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 1867, in
handle_exception
# if we want to repropagate the exception, we can attempt to
# raise it with the whole traceback in case we can do that
# (the function was actually called from the except part)
# otherwise, we just raise the error again
if exc_value is e:
reraise(exc_type, exc_value, tb)
else:
raise e
self.log_exception((exc_type, exc_value, tb))
server_error = InternalServerError()
File "/usr/local/lib/python3.7/site-packages/flask/_compat.py", line 39, in
reraise
import collections.abc as collections_abc
def reraise(tp, value, tb=None):
if value.__traceback__ is not tb:
raise value.with_traceback(tb)
raise value
implements_to_string = _identity
else:
iterkeys = lambda d: d.iterkeys()
File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 2447, in
wsgi_app
ctx = self.request_context(environ)
error = None
try:
try:
ctx.push()
response = self.full_dispatch_request()
except Exception as e:
error = e
response = self.handle_exception(e)
except: # noqa: B001
error = sys.exc_info()[1]
File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 1952, in
full_dispatch_request
request_started.send(self)
rv = self.preprocess_request()
if rv is None:
rv = self.dispatch_request()
except Exception as e:
rv = self.handle_user_exception(e)
return self.finalize_request(rv)
def finalize_request(self, rv, from_error_handler=False):
"""Given the return value from a view function this finalizes
the request by converting it into a response and invoking the
File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 1821, in
handle_user_exception
return self.handle_http_exception(e)
handler = self._find_error_handler(e)
if handler is None:
reraise(exc_type, exc_value, tb)
return handler(e)
def handle_exception(self, e):
"""Handle an exception that did not have an error handler
associated with it, or that was raised from an error handler.
File "/usr/local/lib/python3.7/site-packages/flask/_compat.py", line 39, in
reraise
import collections.abc as collections_abc
def reraise(tp, value, tb=None):
if value.__traceback__ is not tb:
raise value.with_traceback(tb)
raise value
implements_to_string = _identity
else:
iterkeys = lambda d: d.iterkeys()
File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 1950, in
full_dispatch_request
self.try_trigger_before_first_request_functions()
try:
request_started.send(self)
rv = self.preprocess_request()
if rv is None:
rv = self.dispatch_request()
except Exception as e:
rv = self.handle_user_exception(e)
return self.finalize_request(rv)
def finalize_request(self, rv, from_error_handler=False):
File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 1936, in
dispatch_request
getattr(rule, "provide_automatic_options", False)
and req.method == "OPTIONS"
):
return self.make_default_options_response()
# otherwise dispatch to the handler for that endpoint
return self.view_functions[rule.endpoint](**req.view_args)
def full_dispatch_request(self):
"""Dispatches the request and on top of that performs request
pre and postprocessing as well as HTTP exception catching and
error handling.
File "/opt/airflow/airflow/www/auth.py", line 43, in decorated
dag_id = (
request.args.get("dag_id") or request.form.get("dag_id") or
(request.json or {}).get("dag_id")
)
if appbuilder.sm.check_authorization(permissions, dag_id):
return func(*args, **kwargs)
elif not g.user.is_anonymous and not g.user.perms:
return (
render_template(
'airflow/no_roles_permissions.html',
hostname=socket.getfqdn()
File "/opt/airflow/airflow/www/views.py", line 3622, in grid_data
dag_runs =
query.order_by(DagRun.execution_date.desc()).limit(num_runs).all()
dag_runs.reverse()
encoded_runs = [wwwutils.encode_dag_run(dr) for dr in dag_runs]
data = {
'groups': dag_to_grid(dag, dag_runs, session),
'dag_runs': encoded_runs,
}
# avoid spaces to reduce payload size
return (
File "/opt/airflow/airflow/www/views.py", line 396, in dag_to_grid
'children': children,
'tooltip': task_group.tooltip,
'instances': group_summaries,
}
return task_group_to_grid(dag.task_group, dag_runs, grouped_tis)
def task_group_to_dict(task_item_or_group):
"""
Create a nested dict representation of this TaskGroup and its children
used to construct
File "/opt/airflow/airflow/www/views.py", line 357, in task_group_to_grid
# Task Group
task_group = item
children = [
task_group_to_grid(child, dag_runs, grouped_tis) for child in
task_group.topological_sort()
]
def get_summary(dag_run, children):
child_instances = [child['instances'] for child in children if
'instances' in child]
child_instances = [
File "/opt/airflow/airflow/www/views.py", line 357, in <listcomp>
# Task Group
task_group = item
children = [
task_group_to_grid(child, dag_runs, grouped_tis) for child in
task_group.topological_sort()
]
def get_summary(dag_run, children):
child_instances = [child['instances'] for child in children if
'instances' in child]
child_instances = [
File "/opt/airflow/airflow/www/views.py", line 341, in task_group_to_grid
if record:
set_overall_state(record)
yield record
if item.is_mapped:
instances =
list(_mapped_summary(grouped_tis.get(item.task_id, [])))
else:
instances = list(map(_get_summary,
grouped_tis.get(item.task_id, [])))
return {
'id': item.task_id,
File "/opt/airflow/airflow/www/views.py", line 333, in _mapped_summary
'end_date': ti_summary.end_date,
'mapped_states': {ti_summary.state:
ti_summary.state_count},
'state': None, # We change this before yielding
}
continue
record['start_date'] = min(record['start_date'],
ti_summary.start_date)
record['end_date'] = max(record['end_date'],
ti_summary.end_date)
record['mapped_states'][ti_summary.state] =
ti_summary.state_count
if record:
set_overall_state(record)
yield record
TypeError: '<' not supported between instances of 'NoneType' and 'NoneType'
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
