Fix pylint errors: missing __init__.py, import ordering, exception handling

Add customerio/__init__.py so pylint can resolve the package hierarchy.
Fix raise-missing-from, return-in-finally, and import ordering warnings.
Fix RuntimeError formatting bug where %-placeholders were not interpolated.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: richdawe-cio

customerio/__init__.py

@@ -1,19 +1,18 @@
-from datetime import datetime
-from uuid import uuid4
-import logging
-import numbers
 import atexit
 import json
+import logging
+import numbers
+import queue
+from datetime import datetime
+from uuid import uuid4
 
 from dateutil.tz import tzutc
 
-from customerio.analytics.utils import guess_timezone, clean
 from customerio.analytics.consumer import Consumer, MAX_MSG_SIZE
 from customerio.analytics.request import post, DatetimeSerializer
+from customerio.analytics.utils import guess_timezone, clean
 from customerio.analytics.version import VERSION
 
-import queue
-
 ID_TYPES = (numbers.Number, str)
 
 
@@ -269,7 +268,9 @@ def _enqueue(self, msg):
         # Check message size.
         msg_size = len(json.dumps(msg, cls=DatetimeSerializer).encode())
         if msg_size > MAX_MSG_SIZE:
-            raise RuntimeError('Message exceeds %skb limit. (%s)', str(int(MAX_MSG_SIZE / 1024)), str(msg))
+            raise RuntimeError(
+                'Message exceeds %dkb limit. (%s)' % (MAX_MSG_SIZE // 1024, msg)
+            )
 
         # if send is False, return msg as if it was successfully queued
         if not self.send:

customerio/analytics/client.py

@@ -1,13 +1,13 @@
+import json
 import logging
+from queue import Empty
 from threading import Thread
-import monotonic
+
 import backoff
-import json
+import monotonic
 
 from customerio.analytics.request import post, APIError, DatetimeSerializer
 
-from queue import Empty
-
 MAX_MSG_SIZE = 32 << 10
 
 # Our servers only accept batches less than 500KB. Here limit is set slightly
@@ -73,7 +73,7 @@ def upload(self):
             # mark items as acknowledged from queue
             for _ in batch:
                 self.queue.task_done()
-            return success
+        return success
 
     def next(self):
         """Return the next batch of items to upload."""

customerio/analytics/consumer.py

@@ -56,8 +56,8 @@ def post(write_key, host=None, gzip=False, timeout=15, proxies=None, **kwargs):
         payload = res.json()
         log.debug('received response: %s', payload)
         raise APIError(res.status_code, payload['code'], payload['message'])
-    except ValueError:
-        raise APIError(res.status_code, 'unknown', res.text)
+    except ValueError as exc:
+        raise APIError(res.status_code, 'unknown', res.text) from exc
 
 
 class APIError(Exception):

customerio/analytics/request.py

@@ -1,7 +1,8 @@
+import json
+import time
 import unittest
+
 import mock
-import time
-import json
 
 try:
     from queue import Queue