Clean up and migrate to GHA

Signed-off-by: Arcadiy Ivanov <[email protected]>

.github/workflows/build.yml

@@ -0,0 +1,51 @@
+name: fluent-logger
+on:
+  pull_request:
+  push:
+    branches:
+      - master
+jobs:
+  build-stable:
+    runs-on: ${{ matrix.os }}
+    continue-on-error: false
+    strategy:
+      fail-fast: false
+      matrix:
+        os:
+          - ubuntu-latest
+          - windows-latest
+          - macosx-latest
+        python-version:
+          - '3.10'
+          - '3.9'
+          - '3.8'
+          - '3.7'
+          - '3.6'
+          - 'pypy-3.7'
+    env:
+      DEPLOY_PYTHONS: "3.9"
+      DEPLOY_OSES: "Linux"
+      TWINE_USERNAME: __token__
+      TWINE_PASSWORD: ${{ secrets.PYPI_TOKEN }}
+      GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+    steps:
+      - shell: bash
+        if: |
+          github.event_name == 'push' &&
+          contains(env.DEPLOY_OSES, runner.os) &&
+          contains(env.DEPLOY_PYTHONS, matrix.python-version)
+        run: |
+          echo "PYB_EXTRA_ARGS=+upload" >> $GITHUB_ENV
+      - uses: pybuilder/build@master
+        with:
+          python-version: ${{ matrix.python-version }}
+          pyb-extra-args: ${{ env.PYB_EXTRA_ARGS }}
+  build-stable-summary:
+    if: success() || failure()
+    runs-on: ubuntu-latest
+    name: Build Stable Summary
+    needs: build-stable
+    steps:
+      - name: Check build matrix status
+        if: needs.build-stable.result != 'success'
+        run: exit 1

build.py

@@ -32,12 +32,12 @@
 
 @init
 def set_properties(project):
-    project.build_depends_on("docker", "~=4.2.0")
-    project.build_depends_on("cryptography", "~=2.9.0")
+    project.build_depends_on("docker", ">=5.0")
+    project.build_depends_on("cryptography", ">=2.9.0")
 
     project.set_property("verbose", True)
 
-    project.set_property("coverage_break_build", True)
+    project.set_property("coverage_break_build", False)
     project.get_property("coverage_exceptions").extend(["setup"])
 
     project.set_property("flake8_break_build", True)

src/main/python/fluent/sender.py

@@ -16,7 +16,7 @@
 from urllib.parse import urlparse
 from uuid import uuid1
 
-from msgpack import Unpacker, Packer
+from msgpack import Packer
 from msgpack.fallback import Unpacker
 
 DEFAULT_SCHEME = "tcp"
@@ -37,6 +37,7 @@
 
 _endpoint_registry = {}
 
+
 def to_bytes(s):
     if isinstance(s, str):
         return s.encode("utf-8")
@@ -886,7 +887,7 @@ def run(self):
         r_int.add(wakeup_sock_r)
 
         op_queue = self.op_queue
-        last_ts = time.time()
+        # last_ts = time.time()
 
         with wakeup_sock_r, self.wakeup_sock_w:
             while r_int or w_int:
@@ -909,7 +910,7 @@ def run(self):
                                     r_int.remove(r)
                                     break
                                 elif cmd == NEW_OP:
-                                    enable, op, conn = op_queue.pop()  # type: EndpointOp
+                                    enable, op, conn = op_queue.pop()
                                     if op == OP_READ:
                                         if enable:
                                             r_int.add(conn)

src/unittest/python/fluentd_tester.py

@@ -1,6 +1,7 @@
 import os
 import tempfile
 from collections import namedtuple
+
 import docker
 
 """
@@ -32,7 +33,8 @@ def __init__(self, config, *, port_generator, docker, data_dir):
         self.data_dir = data_dir
 
     def start(self):
-
+        pass
+
     def cleanup(self):
         self.config_dir.cleanup()
         if self.config.proto.startswith("unix"):
@@ -59,7 +61,7 @@ def port_generator():
                                                     data_dir=self.data_dir)
 
     def setUp(self):
-
+        pass
 
     def tearDown(self):
         for config in self.instances: