Replace pkg_resource with importlib.metadata

Author: ndevenish

.pre-commit-config.yaml

@@ -32,7 +32,6 @@ repos:
     files: 'src/.*\.py$'
     additional_dependencies:
     - types-requests
-    - types-pkg_resources
     - types-pyyaml
 
 - repo: https://github.com/python-poetry/poetry

src/zocalo/cli/wrap.py

@@ -11,8 +11,8 @@
 import logging
 import signal
 import sys
+from importlib.metadata import entry_points
 
-import pkg_resources
 import workflows.recipe.wrapper
 import workflows.services.common_service
 import workflows.transport
@@ -40,9 +40,7 @@ def run():
     zc = zocalo.configuration.from_file()
     zc.activate()
 
-    known_wrappers = {
-        e.name: e.load for e in pkg_resources.iter_entry_points("zocalo.wrappers")
-    }
+    known_wrappers = {e.name: e.load for e in entry_points(group="zocalo.wrappers")}
 
     # Set up parser
     parser = argparse.ArgumentParser(usage="zocalo.wrap [options]")

src/zocalo/configuration/__init__.py

@@ -9,9 +9,9 @@
 import os
 import pathlib
 import typing
+from importlib.metadata import entry_points
 
 import marshmallow as mm
-import pkg_resources
 import yaml
 
 import zocalo.configuration.argparse
@@ -56,7 +56,7 @@ def _check_valid_plugin_name(name: str) -> bool:
 
 _configuration_plugins = {
     e.name: e
-    for e in pkg_resources.iter_entry_points("zocalo.configuration.plugins")
+    for e in entry_points(group="zocalo.configuration.plugins")
     if _check_valid_plugin_name(e.name)
 }
 

src/zocalo/service/dispatcher.py

@@ -8,8 +8,8 @@
 import time
 import timeit
 import uuid
+from importlib.metadata import entry_points
 
-import pkg_resources
 import workflows.recipe
 from workflows.services.common_service import CommonService
 
@@ -110,9 +110,7 @@ def initializing(self):
         self.message_filters = {
             **{
                 f.name: f.load()
-                for f in pkg_resources.iter_entry_points(
-                    "zocalo.services.dispatcher.filters"
-                )
+                for f in entry_points(group="zocalo.services.dispatcher.filters")
             },
             "load_custom_recipe": self.filter_load_custom_recipe,
             "load_recipes_from_files": self.filter_load_recipes_from_files,
@@ -121,8 +119,8 @@ def initializing(self):
 
         self.ready_for_processing = {
             f.name: f.load()
-            for f in pkg_resources.iter_entry_points(
-                "zocalo.services.dispatcher.ready_for_processing"
+            for f in entry_points(
+                group="zocalo.services.dispatcher.ready_for_processing"
             )
         }