Skip to content

Commit

Permalink
Fix issue with Flask instrumentation when a request spawn children th…
Browse files Browse the repository at this point in the history
…reads and copie the request context
  • Loading branch information
hangonlyra committed Feb 9, 2023
1 parent 7af87e1 commit 1e36cca
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 5 deletions.
2 changes: 1 addition & 1 deletion CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
([#1618](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/1618))

### Fixed

- Fix Flask instrumentation to only close the span if it was created by the same thread. `ValueError: generator already executing` ([#1653](https://github.com/open-telemetry/opentelemetry-python-contrib/issues/1653))
- Fix TortoiseORM instrumentation `AttributeError: type object 'Config' has no attribute 'title'`
([#1575](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/1575))
- Fix SQLAlchemy uninstrumentation
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -238,10 +238,10 @@ def response_hook(span: Span, status: str, response_headers: List):
API
---
"""

from logging import getLogger
from time import time_ns
from timeit import default_timer
from threading import get_ident
from typing import Collection

import flask
Expand Down Expand Up @@ -397,7 +397,10 @@ def _before_request():

activation = trace.use_span(span, end_on_exit=True)
activation.__enter__() # pylint: disable=E1101
flask_request_environ[_ENVIRON_ACTIVATION_KEY] = activation
flask_request_environ[_ENVIRON_ACTIVATION_KEY] = (
get_ident(),
activation,
)
flask_request_environ[_ENVIRON_SPAN_KEY] = span
flask_request_environ[_ENVIRON_TOKEN] = token

Expand Down Expand Up @@ -436,8 +439,10 @@ def _teardown_request(exc):
if excluded_urls and excluded_urls.url_disabled(flask.request.url):
return

activation = flask.request.environ.get(_ENVIRON_ACTIVATION_KEY)
if not activation:
thread_id, activation = flask.request.environ.get(
_ENVIRON_ACTIVATION_KEY
)
if not activation or thread_id != get_ident():
# This request didn't start a span, maybe because it was created in
# a way that doesn't run `before_request`, like when it is created
# with `app.test_request_context`.
Expand Down

0 comments on commit 1e36cca

Please sign in to comment.