Update core pipeline to adapt to OT 1.0

sdk/core/azure-core-tracing-opencensus/tests/test_tracing_implementations.py

@@ -141,7 +141,6 @@ def test_set_http_attributes(self):
             setattr(request, "headers", {})
             setattr(response, "status_code", 200)
             wrapped_class.set_http_attributes(request)
-            assert wrapped_class.span_instance.span_kind == OpenCensusSpanKind.CLIENT
             assert wrapped_class.span_instance.attributes.get("http.method") == request.method
             assert wrapped_class.span_instance.attributes.get("component") == "http"
             assert wrapped_class.span_instance.attributes.get("http.url") == request.url

sdk/core/azure-core-tracing-opentelemetry/tests/test_tracing_implementations.py

@@ -148,7 +148,6 @@ def test_set_http_attributes(self, tracer):
             setattr(request, "headers", {})
             setattr(response, "status_code", 200)
             wrapped_class.set_http_attributes(request)
-            assert wrapped_class.span_instance.kind == OpenTelemetrySpanKind.CLIENT
             assert wrapped_class.span_instance.attributes.get("http.method") == request.method
             assert wrapped_class.span_instance.attributes.get("component") == "http"
             assert wrapped_class.span_instance.attributes.get("http.url") == request.url

sdk/core/azure-core/azure/core/pipeline/policies/_distributed_tracing.py

@@ -30,6 +30,7 @@
 
 from azure.core.pipeline.policies import SansIOHTTPPolicy
 from azure.core.settings import settings
+from azure.core.tracing import SpanKind
 
 try:
     from typing import TYPE_CHECKING
@@ -90,7 +91,7 @@ def on_request(self, request):
             namer = ctxt.pop('network_span_namer', self._network_span_namer)
             span_name = namer(request.http_request)
 
-            span = span_impl_type(name=span_name)
+            span = span_impl_type(name=span_name, kind=SpanKind.CLIENT)
             for attr, value in self._tracing_attributes.items():
                 span.add_attribute(attr, value)
             span.start()

sdk/core/azure-core/azure/core/tracing/_abstract_span.py

@@ -221,7 +221,6 @@ def set_http_attributes(self, request, response=None):
         :param response: The response received by the server. Is None if no response received.
         :type response: ~azure.core.pipeline.transport.HttpResponse or ~azure.core.pipeline.transport.AsyncHttpResponse
         """
-        self.kind = SpanKind.CLIENT
         self.add_attribute(self._SPAN_COMPONENT, "http")
         self.add_attribute(self._HTTP_METHOD, request.method)
         self.add_attribute(self._HTTP_URL, request.url)

sdk/core/azure-core/tests/tracing_common.py

@@ -22,7 +22,7 @@ class FakeSpan(HttpSpanMixin, object):
     # Keep a fake context of the current one
     CONTEXT = []
 
-    def __init__(self, span=None, name="span"):
+    def __init__(self, span=None, name="span", kind=None):
         # type: (Optional[Span], Optional[str]) -> None
         """
         If a span is not passed in, creates a new tracer. If the instrumentation key for Azure Exporter is given, will
@@ -35,7 +35,7 @@ def __init__(self, span=None, name="span"):
         """
         self._span = span
         self.name = name
-        self._kind = SpanKind.UNSPECIFIED
+        self._kind = kind or SpanKind.UNSPECIFIED
         self.attributes = {}
         self.children = []
         if self.CONTEXT: