Format all files with black.

docs/conf.py

@@ -12,65 +12,66 @@
 
 import os
 import sys
-sys.path.insert(0, os.path.abspath('../opentelemetry-api/src/'))
+
+sys.path.insert(0, os.path.abspath("../opentelemetry-api/src/"))
 
 
 # -- Project information -----------------------------------------------------
 
-project = 'OpenTelemetry'
-copyright = '2019, OpenTelemetry Authors'
-author = 'OpenTelemetry Authors'
+project = "OpenTelemetry"
+copyright = "2019, OpenTelemetry Authors"
+author = "OpenTelemetry Authors"
 
 
 # -- General configuration ---------------------------------------------------
 
 # Easy automatic cross-references for `code in backticks`
-default_role = 'any'
+default_role = "any"
 
 # Add any Sphinx extension module names here, as strings. They can be
 # extensions coming with Sphinx (named 'sphinx.ext.*') or your custom
 # ones.
 extensions = [
     # API doc generation
-    'sphinx.ext.autodoc',
+    "sphinx.ext.autodoc",
     # Support for google-style docstrings
-    'sphinx.ext.napoleon',
+    "sphinx.ext.napoleon",
     # Infer types from hints instead of docstrings
-    'sphinx_autodoc_typehints',
+    "sphinx_autodoc_typehints",
     # Add links to source from generated docs
-    'sphinx.ext.viewcode',
+    "sphinx.ext.viewcode",
     # Link to other sphinx docs
-    'sphinx.ext.intersphinx',
+    "sphinx.ext.intersphinx",
 ]
 
-intersphinx_mapping = {'python': ('https://docs.python.org/3/', None)}
+intersphinx_mapping = {"python": ("https://docs.python.org/3/", None)}
 
 # http://www.sphinx-doc.org/en/master/config.html#confval-nitpicky
 # Sphinx will warn about all references where the target cannot be found.
 nitpicky = True
 nitpick_ignore = []
 
 # Add any paths that contain templates here, relative to this directory.
-templates_path = ['_templates']
+templates_path = ["_templates"]
 
 # List of patterns, relative to source directory, that match files and
 # directories to ignore when looking for source files.
 # This pattern also affects html_static_path and html_extra_path.
-exclude_patterns = ['_build', 'Thumbs.db', '.DS_Store']
+exclude_patterns = ["_build", "Thumbs.db", ".DS_Store"]
 
 autodoc_default_options = {
-    'members': True,
-    'undoc-members': True,
-    'show-inheritance': True,
-    'member-order': 'bysource'
+    "members": True,
+    "undoc-members": True,
+    "show-inheritance": True,
+    "member-order": "bysource",
 }
 
 # -- Options for HTML output -------------------------------------------------
 
 # The theme to use for HTML and HTML Help pages.  See the documentation for
 # a list of builtin themes.
 #
-html_theme = 'sphinx_rtd_theme'
+html_theme = "sphinx_rtd_theme"
 
 # Add any paths that contain custom static files (such as style sheets) here,
 # relative to this directory. They are copied after the builtin static files,

ext/opentelemetry-ext-http-requests/setup.py

@@ -16,12 +16,7 @@
 
 BASE_DIR = os.path.dirname(__file__)
 VERSION_FILENAME = os.path.join(
-    BASE_DIR,
-    "src",
-    "opentelemetry",
-    "ext",
-    "http_requests",
-    "version.py",
+    BASE_DIR, "src", "opentelemetry", "ext", "http_requests", "version.py"
 )
 PACKAGE_INFO = {}
 with open(VERSION_FILENAME) as f:

ext/opentelemetry-ext-http-requests/tests/test_requests_integration.py

@@ -16,9 +16,7 @@ def setUp(self):
         self.span_attrs = {}
         self.tracer = trace.tracer()
         self.span_context_manager = mock.MagicMock()
-        self.span = mock.create_autospec(
-            trace.Span, spec_set=True
-        )
+        self.span = mock.create_autospec(trace.Span, spec_set=True)
         self.span_context_manager.__enter__.return_value = self.span
 
         def setspanattr(key, value):
@@ -31,16 +29,20 @@ def setspanattr(key, value):
             "start_span",
             autospec=True,
             spec_set=True,
-            return_value=self.span_context_manager
+            return_value=self.span_context_manager,
         )
         self.start_span = self.start_span_patcher.start()
 
         mocked_response = requests.models.Response()
         mocked_response.status_code = 200
         mocked_response.reason = "Roger that!"
         self.send_patcher = mock.patch.object(
-            requests.Session, "send", autospec=True, spec_set=True,
-            return_value=mocked_response)
+            requests.Session,
+            "send",
+            autospec=True,
+            spec_set=True,
+            return_value=mocked_response,
+        )
         self.send = self.send_patcher.start()
 
         opentelemetry.ext.http_requests.enable(self.tracer)
@@ -57,33 +59,39 @@ def test_basic(self):
         self.tracer.start_span.assert_called_with("/foo/bar")
         self.span_context_manager.__enter__.assert_called_with()
         self.span_context_manager.__exit__.assert_called_with(None, None, None)
-        self.assertEqual(self.span_attrs, {
-            "component": "http",
-            "http.method": "GET",
-            "http.url": url,
-            "http.status_code": 200,
-            "http.status_text": "Roger that!"
-        })
+        self.assertEqual(
+            self.span_attrs,
+            {
+                "component": "http",
+                "http.method": "GET",
+                "http.url": url,
+                "http.status_code": 200,
+                "http.status_text": "Roger that!",
+            },
+        )
 
     def test_invalid_url(self):
         url = "http://[::1/nope"
         exception_type = requests.exceptions.InvalidURL
-        if (sys.version_info[:2] < (3, 5)
-                and tuple(map(
-                    int, urllib3.__version__.split('.')[:2])) < (1, 25)):
+        if sys.version_info[:2] < (3, 5) and tuple(
+            map(int, urllib3.__version__.split(".")[:2])
+        ) < (1, 25):
             exception_type = ValueError
 
         with self.assertRaises(exception_type):
             _response = requests.post(url=url)
-        self.assertTrue(self.tracer.start_span.call_args[0][0].startswith(
-            "<Unparsable URL"), msg=self.tracer.start_span.call_args)
+        self.assertTrue(
+            self.tracer.start_span.call_args[0][0].startswith(
+                "<Unparsable URL"
+            ),
+            msg=self.tracer.start_span.call_args,
+        )
         self.span_context_manager.__enter__.assert_called_with()
         exitspan = self.span_context_manager.__exit__
         self.assertEqual(1, len(exitspan.call_args_list))
         self.assertIs(exception_type, exitspan.call_args[0][0])
         self.assertIsInstance(exitspan.call_args[0][1], exception_type)
-        self.assertEqual(self.span_attrs, {
-            "component": "http",
-            "http.method": "POST",
-            "http.url": url,
-        })
+        self.assertEqual(
+            self.span_attrs,
+            {"component": "http", "http.method": "POST", "http.url": url},
+        )

ext/opentelemetry-ext-wsgi/setup.py

@@ -16,12 +16,7 @@
 
 BASE_DIR = os.path.dirname(__file__)
 VERSION_FILENAME = os.path.join(
-    BASE_DIR,
-    "src",
-    "opentelemetry",
-    "ext",
-    "wsgi",
-    "version.py",
+    BASE_DIR, "src", "opentelemetry", "ext", "wsgi", "version.py"
 )
 PACKAGE_INFO = {}
 with open(VERSION_FILENAME) as f:

ext/opentelemetry-ext-wsgi/src/opentelemetry/ext/wsgi/__init__.py

@@ -35,11 +35,7 @@ class OpenTelemetryMiddleware:
         wsgi: The WSGI application callable.
     """
 
-    def __init__(
-            self,
-            wsgi,
-            propagators=None,
-    ):
+    def __init__(self, wsgi, propagators=None):
         self.wsgi = wsgi
 
         # TODO: implement context propagation
@@ -54,9 +50,9 @@ def _add_request_attributes(span, environ):
         span.set_attribute("http.host", host)
 
         url = (
-            environ.get("REQUEST_URI") or
-            environ.get("RAW_URI") or
-            wsgiref_util.request_uri(environ, include_query=False)
+            environ.get("REQUEST_URI")
+            or environ.get("RAW_URI")
+            or wsgiref_util.request_uri(environ, include_query=False)
         )
         span.set_attribute("http.url", url)
 
@@ -101,5 +97,5 @@ def __call__(self, environ, start_response):
                 for yielded in iterable:
                     yield yielded
             finally:
-                if hasattr(iterable, 'close'):
+                if hasattr(iterable, "close"):
                     iterable.close()

ext/opentelemetry-ext-wsgi/tests/test_wsgi_middleware.py

@@ -48,6 +48,7 @@ def iter_wsgi(environ, start_response):
         assert isinstance(environ, dict)
         start_response("200 OK", [("Content-Type", "text/plain")])
         return response
+
     return iter_wsgi
 
 
@@ -66,10 +67,9 @@ class TestWsgiApplication(unittest.TestCase):
     def setUp(self):
         tracer = trace_api.tracer()
         self.span_context_manager = mock.MagicMock()
-        self.span_context_manager.__enter__.return_value = \
-            mock.create_autospec(
-                trace_api.Span, spec_set=True
-            )
+        self.span_context_manager.__enter__.return_value = mock.create_autospec(
+            trace_api.Span, spec_set=True
+        )
         self.patcher = mock.patch.object(
             tracer,
             "start_span",
@@ -115,8 +115,7 @@ def validate_response(self, response, error=None):
 
         self.assertEqual(self.status, "200 OK")
         self.assertEqual(
-            self.response_headers,
-            [("Content-Type", "text/plain")]
+            self.response_headers, [("Content-Type", "text/plain")]
         )
         if error:
             self.assertIs(self.exc_info[0], error)
@@ -159,8 +158,7 @@ def setUp(self):
 
     def test_request_attributes(self):
         OpenTelemetryMiddleware._add_request_attributes(  # noqa pylint: disable=protected-access
-            self.span,
-            self.environ,
+            self.span, self.environ
         )
         expected = (
             mock.call("component", "http"),
@@ -173,7 +171,7 @@ def test_request_attributes(self):
 
     def test_response_attributes(self):
         OpenTelemetryMiddleware._add_response_attributes(  # noqa pylint: disable=protected-access
-            self.span, "404 Not Found",
+            self.span, "404 Not Found"
         )
         expected = (
             mock.call("http.status_code", 404),
@@ -184,12 +182,11 @@ def test_response_attributes(self):
 
     def test_response_attributes_invalid_status_code(self):
         OpenTelemetryMiddleware._add_response_attributes(  # noqa pylint: disable=protected-access
-            self.span, "Invalid Status Code",
+            self.span, "Invalid Status Code"
         )
         self.assertEqual(self.span.set_attribute.call_count, 1)
         self.span.set_attribute.assert_called_with(
-            "http.status_text",
-            "Status Code",
+            "http.status_text", "Status Code"
         )
 
 

opentelemetry-api/setup.py

@@ -41,15 +41,16 @@
     description="OpenTelemetry Python API",
     include_package_data=True,
     long_description=open("README.rst").read(),
-    install_requires=[
-        "typing; python_version<'3.5'",
-    ],
+    install_requires=["typing; python_version<'3.5'"],
     extras_require={},
     license="Apache-2.0",
     package_dir={"": "src"},
-    packages=setuptools.find_namespace_packages(where="src",
-                                                include="opentelemetry.*"),
-    url=("https://github.com/open-telemetry/opentelemetry-python"
-         "/tree/master/opentelemetry-api"),
+    packages=setuptools.find_namespace_packages(
+        where="src", include="opentelemetry.*"
+    ),
+    url=(
+        "https://github.com/open-telemetry/opentelemetry-python"
+        "/tree/master/opentelemetry-api"
+    ),
     zip_safe=False,
 )

opentelemetry-api/src/opentelemetry/context/__init__.py

@@ -142,14 +142,16 @@ async def main():
 
 from .base_context import BaseRuntimeContext
 
-__all__ = ['Context']
+__all__ = ["Context"]
 
 
 Context = None  # type: typing.Optional[BaseRuntimeContext]
 
 try:
     from .async_context import AsyncRuntimeContext
+
     Context = AsyncRuntimeContext()
 except ImportError:
     from .thread_local_context import ThreadLocalRuntimeContext
+
     Context = ThreadLocalRuntimeContext()

opentelemetry-api/src/opentelemetry/context/async_context.py

@@ -20,7 +20,7 @@
 
 class AsyncRuntimeContext(base_context.BaseRuntimeContext):
     class Slot(base_context.BaseRuntimeContext.Slot):
-        def __init__(self, name: str, default: 'object'):
+        def __init__(self, name: str, default: "object"):
             # pylint: disable=super-init-not-called
             self.name = name
             self.contextvar = ContextVar(name)  # type: ContextVar[object]
@@ -31,13 +31,13 @@ def __init__(self, name: str, default: 'object'):
         def clear(self) -> None:
             self.contextvar.set(self.default())
 
-        def get(self) -> 'object':
+        def get(self) -> "object":
             try:
                 return self.contextvar.get()
             except LookupError:
                 value = self.default()
                 self.set(value)
                 return value
 
-        def set(self, value: 'object') -> None:
+        def set(self, value: "object") -> None:
             self.contextvar.set(value)