Address warning and deprecation messages (#218)

* Use raw strings for regexes containing escape sequences

* Use == and != to compare to literals

Author: Andrew Slotin

instana/agent.py

@@ -161,7 +161,7 @@ def announce(self, discovery):
                                        headers={"Content-Type": "application/json"},
                                        timeout=0.8)
 
-            if response.status_code is 200:
+            if response.status_code == 200:
                 self.last_seen = datetime.now()
         except (requests.ConnectTimeout, requests.ConnectionError):
             logger.debug("announce", exc_info=True)
@@ -175,7 +175,7 @@ def is_agent_ready(self):
         try:
             response = self.client.head(self.__data_url(), timeout=0.8)
 
-            if response.status_code is 200:
+            if response.status_code == 200:
                 return True
             return False
         except (requests.ConnectTimeout, requests.ConnectionError):
@@ -194,7 +194,7 @@ def report_data(self, entity_data):
 
             # logger.warn("report_data: response.status_code is %s" % response.status_code)
 
-            if response.status_code is 200:
+            if response.status_code == 200:
                 self.last_seen = datetime.now()
         except (requests.ConnectTimeout, requests.ConnectionError):
             logger.debug("report_data: Instana host agent connection error")
@@ -219,7 +219,7 @@ def report_traces(self, spans):
 
             # logger.warn("report_traces: response.status_code is %s" % response.status_code)
 
-            if response.status_code is 200:
+            if response.status_code == 200:
                 self.last_seen = datetime.now()
         except (requests.ConnectTimeout, requests.ConnectionError):
             logger.debug("report_traces: Instana host agent connection error")

instana/fsm.py

@@ -156,7 +156,7 @@ def announce_sensor(self, e):
 
         response = self.agent.announce(d)
 
-        if response and (response.status_code is 200) and (len(response.content) > 2):
+        if response and (response.status_code == 200) and (len(response.content) > 2):
             self.agent.set_from(response.content)
             self.fsm.pending()
             logger.debug("Announced pid: %s (true pid: %s).  Waiting for Agent Ready...", str(pid), str(self.agent.from_.pid))

instana/instrumentation/aiohttp/server.py

@@ -44,7 +44,7 @@ async def stan_middleware(request, handler):
                 if 500 <= response.status <= 511:
                     scope.span.set_tag("error", True)
                     ec = scope.span.tags.get('ec', 0)
-                    if ec is 0:
+                    if ec == 0:
                         scope.span.set_tag("ec", ec + 1)
 
                 scope.span.set_tag("http.status_code", response.status)

instana/instrumentation/django/middleware.py

@@ -55,7 +55,7 @@ def process_response(self, request, response):
                 if 500 <= response.status_code <= 511:
                     request.iscope.span.set_tag("error", True)
                     ec = request.iscope.span.tags.get('ec', 0)
-                    if ec is 0:
+                    if ec == 0:
                         request.iscope.span.set_tag("ec", ec+1)
 
                 request.iscope.span.set_tag(ext.HTTP_STATUS_CODE, response.status_code)

instana/instrumentation/flask/vanilla.py

@@ -66,7 +66,7 @@ def after_request_with_instana(response):
             if 500 <= response.status_code <= 511:
                 span.set_tag("error", True)
                 ec = span.tags.get('ec', 0)
-                if ec is 0:
+                if ec == 0:
                     span.set_tag("ec", ec+1)
 
             span.set_tag(ext.HTTP_STATUS_CODE, int(response.status_code))

instana/instrumentation/flask/with_blinker.py

@@ -64,7 +64,7 @@ def request_finished_with_instana(sender, response, **extra):
             if 500 <= response.status_code <= 511:
                 span.set_tag("error", True)
                 ec = span.tags.get('ec', 0)
-                if ec is 0:
+                if ec == 0:
                     span.set_tag("ec", ec+1)
 
             span.set_tag(ext.HTTP_STATUS_CODE, int(response.status_code))

instana/instrumentation/sqlalchemy.py

@@ -10,7 +10,7 @@
     from sqlalchemy import event
     from sqlalchemy.engine import Engine
 
-    url_regexp = re.compile('\/\/(\S+@)')
+    url_regexp = re.compile(r"\/\/(\S+@)")
 
     @event.listens_for(Engine, 'before_cursor_execute', named=True)
     def receive_before_cursor_execute(**kw):

instana/instrumentation/tornado/server.py

@@ -79,7 +79,7 @@ def on_finish_with_instana(wrapped, instance, argv, kwargs):
                 if 500 <= status_code <= 511:
                     scope.span.set_tag("error", True)
                     ec = scope.span.tags.get('ec', 0)
-                    if ec is 0:
+                    if ec == 0:
                         scope.span.set_tag("ec", ec + 1)
 
                 scope.span.set_tag("http.status_code", status_code)

instana/instrumentation/urllib3.py

@@ -18,7 +18,7 @@ def collect(instance, args, kwargs):
             kvs['host'] = instance.host
             kvs['port'] = instance.port
 
-            if args is not None and len(args) is 2:
+            if args is not None and len(args) == 2:
                 kvs['method'] = args[0]
                 kvs['path'] = args[1]
             else:
@@ -31,7 +31,7 @@ def collect(instance, args, kwargs):
             if kvs.get('path') is not None and ('?' in kvs['path']):
                 parts = kvs['path'].split('?')
                 kvs['path'] = parts[0]
-                if len(parts) is 2:
+                if len(parts) == 2:
                     kvs['query'] = strip_secrets(parts[1], agent.secrets_matcher, agent.secrets_list)
 
             if type(instance) is urllib3.connectionpool.HTTPSConnectionPool:

instana/meter.py

@@ -188,10 +188,10 @@ def metric_work():
     def process(self):
         """ Collects, processes & reports metrics """
         try:
-            if self.agent.machine.fsm.current is "wait4init":
+            if self.agent.machine.fsm.current == "wait4init":
                 # Test the host agent if we're ready to send data
                 if self.agent.is_agent_ready():
-                    if self.agent.machine.fsm.current is not "good2go":
+                    if self.agent.machine.fsm.current != "good2go":
                         self.agent.machine.fsm.ready()
                 else:
                     return
@@ -216,7 +216,7 @@ def process(self):
             response = self.agent.report_data(ed)
 
             if response:
-                if response.status_code is 200 and len(response.content) > 2:
+                if response.status_code == 200 and len(response.content) > 2:
                     # The host agent returned something indicating that is has a request for us that we
                     # need to process.
                     self.handle_agent_tasks(json.loads(response.content)[0])