Release for v0.7.11 (#958)

Author: lzchen

.isort.cfg

@@ -14,4 +14,4 @@ line_length=79
 multi_line_output=3
 known_future_library = six,six.moves,__future__
 known_third_party=google,mock,pymysql,sqlalchemy,psycopg2,mysql,requests,django,pytest,grpc,flask,bitarray,prometheus_client,psutil,pymongo,wrapt,thrift,retrying,pyramid,werkzeug,gevent
-known_first_party=opencensus
+known_first_party=opencensus

.travis.yml

@@ -15,7 +15,3 @@ install:
 script:
   - tox
   - touch docs/.nojekyll
-
-branches:
-  only:
-    - master

CHANGELOG.md

@@ -12,4 +12,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-__version__ = '0.2.dev0'
+__version__ = '0.1.2'

context/opencensus-context/CHANGELOG.md

@@ -12,4 +12,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-__version__ = '0.4.dev0'
+__version__ = '0.3.0'

context/opencensus-context/version.py

@@ -67,7 +67,7 @@ def __init__(self, src, dst):
 
     def run(self):  # pragma: NO COVER
         # Indicate that this thread is an exporter thread.
-        # Used to suppress tracking of requests in this thread
+        # Used to suppress tracking of requests in this thread.
         execution_context.set_is_exporter(True)
         src = self.src
         dst = self.dst

contrib/opencensus-correlation/version.py

@@ -12,4 +12,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-__version__ = '1.0.dev0'
+__version__ = '1.0.5'

contrib/opencensus-ext-azure/CHANGELOG.md

@@ -81,6 +81,24 @@ def _export(self, batch, event=None):  # pragma: NO COVER
             if event:
                 event.set()
 
+    def _export(self, batch, event=None):  # pragma: NO COVER
+        try:
+            if batch:
+                envelopes = [self.log_record_to_envelope(x) for x in batch]
+                envelopes = self.apply_telemetry_processors(envelopes)
+                result = self._transmit(envelopes)
+                if result > 0:
+                    self.storage.put(envelopes, result)
+            if event:
+                if isinstance(event, QueueExitEvent):
+                    self._transmit_from_storage()  # send files before exit
+                return
+            if len(batch) < self.options.max_batch_size:
+                self._transmit_from_storage()
+        finally:
+            if event:
+                event.set()
+
     def close(self):
         self.storage.close()
         self._worker.stop()