Fix tox issues

extensions/eda/plugins/event_source/alertmanager.py

@@ -32,6 +32,8 @@
 
 """
 
+from __future__ import annotations
+
 import asyncio
 import logging
 from typing import Any
@@ -144,7 +146,7 @@ async def main(queue: asyncio.Queue, args: dict[str, Any]) -> None:
     class MockQueue:
         """A fake queue."""
 
-        async def put(self: "MockQueue", event: dict) -> None:
+        async def put(self: MockQueue, event: dict) -> None:
             """Print the event."""
             print(event)  # noqa: T201
 

extensions/eda/plugins/event_source/aws_cloudtrail.py

@@ -31,14 +31,18 @@
 
 """
 
+from __future__ import annotations
+
 import asyncio
 import json
 from datetime import datetime
-from typing import Any
+from typing import TYPE_CHECKING, Any
 
-from aiobotocore.client import BaseClient
 from aiobotocore.session import get_session
 
+if TYPE_CHECKING:
+    from aiobotocore.client import BaseClient
+
 
 def _cloudtrail_event_to_dict(event: dict) -> dict:
     event["EventTime"] = event["EventTime"].isoformat()
@@ -131,7 +135,7 @@ def connection_args(args: dict[str, Any]) -> dict[str, Any]:
     class MockQueue:
         """A fake queue."""
 
-        async def put(self: "MockQueue", event: dict) -> None:
+        async def put(self: MockQueue, event: dict) -> None:
             """Print the event."""
             print(event)  # noqa: T201
 

extensions/eda/plugins/event_source/aws_sqs_queue.py

@@ -21,6 +21,8 @@
 
 """
 
+from __future__ import annotations
+
 import asyncio
 import json
 import logging
@@ -109,7 +111,7 @@ def connection_args(args: dict[str, Any]) -> dict[str, Any]:
     class MockQueue:
         """A fake queue."""
 
-        async def put(self: "MockQueue", event: dict) -> None:
+        async def put(self: MockQueue, event: dict) -> None:
             """Print the event."""
             print(event)  # noqa: T201
 

extensions/eda/plugins/event_source/azure_service_bus.py

@@ -16,6 +16,8 @@
 
 """
 
+from __future__ import annotations
+
 import asyncio
 import concurrent.futures
 import contextlib
@@ -69,7 +71,7 @@ async def main(
     class MockQueue:
         """A fake queue."""
 
-        async def put_nowait(self: "MockQueue", event: dict) -> None:
+        async def put_nowait(self: MockQueue, event: dict) -> None:
             """Print the event."""
             print(event)  # noqa: T201
 

extensions/eda/plugins/event_source/file.py

@@ -15,6 +15,8 @@
 
 """
 
+from __future__ import annotations
+
 import pathlib
 
 import yaml
@@ -60,21 +62,21 @@ def _observe_files(queue, files: list[str]) -> None:  # noqa: ANN001
     class Handler(RegexMatchingEventHandler):
         """A handler for file events."""
 
-        def __init__(self: "Handler", **kwargs) -> None:  # noqa: ANN003
+        def __init__(self: Handler, **kwargs) -> None:  # noqa: ANN003
             RegexMatchingEventHandler.__init__(self, **kwargs)
 
-        def on_created(self: "Handler", event: dict) -> None:
+        def on_created(self: Handler, event: dict) -> None:
             if event.src_path in files:
                 send_facts(queue, event.src_path)
 
-        def on_deleted(self: "Handler", event: dict) -> None:
+        def on_deleted(self: Handler, event: dict) -> None:
             pass
 
-        def on_modified(self: "Handler", event: dict) -> None:
+        def on_modified(self: Handler, event: dict) -> None:
             if event.src_path in files:
                 send_facts(queue, event.src_path)
 
-        def on_moved(self: "Handler", event: dict) -> None:
+        def on_moved(self: Handler, event: dict) -> None:
             pass
 
     observer = Observer()
@@ -98,7 +100,7 @@ def on_moved(self: "Handler", event: dict) -> None:
     class MockQueue:
         """A fake queue."""
 
-        async def put(self: "MockQueue", event: dict) -> None:
+        async def put(self: MockQueue, event: dict) -> None:
             """Print the event."""
             print(event)  # noqa: T201
 

extensions/eda/plugins/event_source/generic.py

@@ -41,6 +41,8 @@
 #  See the License for the specific language governing permissions and
 #  limitations under the License.
 
+from __future__ import annotations
+
 import asyncio
 import random
 import time
@@ -128,7 +130,7 @@ def _create_data(
     class MockQueue:
         """A fake queue."""
 
-        async def put(self: "MockQueue", event: dict) -> None:
+        async def put(self: MockQueue, event: dict) -> None:
             """Print the event."""
             print(event)  # noqa: T201
 

extensions/eda/plugins/event_source/journald.py

@@ -23,6 +23,8 @@
 
 """
 
+from __future__ import annotations
+
 import asyncio
 from typing import Any
 

extensions/eda/plugins/event_source/kafka.py

@@ -24,6 +24,8 @@
 
 """
 
+from __future__ import annotations
+
 import asyncio
 import json
 import logging
@@ -103,7 +105,7 @@ async def main(  # pylint: disable=R0914
     class MockQueue:
         """A fake queue."""
 
-        async def put(self: "MockQueue", event: dict) -> None:
+        async def put(self: MockQueue, event: dict) -> None:
             """Print the event."""
             print(event)  # noqa: T201
 

extensions/eda/plugins/event_source/range.py

@@ -14,6 +14,8 @@
 
 """
 
+from __future__ import annotations
+
 import asyncio
 from typing import Any
 
@@ -33,7 +35,7 @@ async def main(queue: asyncio.Queue, args: dict[str, Any]) -> None:
     class MockQueue:
         """A fake queue."""
 
-        async def put(self: "MockQueue", event: dict) -> None:
+        async def put(self: MockQueue, event: dict) -> None:
             """Print the event."""
             print(event)  # noqa: T201
 

extensions/eda/plugins/event_source/tick.py

@@ -13,6 +13,9 @@
         delay: 5
 
 """
+
+from __future__ import annotations
+
 import asyncio
 import itertools
 from typing import Any
@@ -33,7 +36,7 @@ async def main(queue: asyncio.Queue, args: dict[str, Any]) -> None:
     class MockQueue:
         """A fake queue."""
 
-        async def put(self: "MockQueue", event: dict) -> None:
+        async def put(self: MockQueue, event: dict) -> None:
             """Print the event."""
             print(event)  # noqa: T201
 

extensions/eda/plugins/event_source/url_check.py

@@ -19,6 +19,8 @@
 
 """
 
+from __future__ import annotations
+
 import asyncio
 from typing import Any
 
@@ -72,7 +74,7 @@ async def main(queue: asyncio.Queue, args: dict[str, Any]) -> None:
     class MockQueue:
         """A fake queue."""
 
-        async def put(self: "MockQueue", event: dict) -> None:
+        async def put(self: MockQueue, event: dict) -> None:
             """Print the event."""
             print(event)  # noqa: T201
 

extensions/eda/plugins/event_source/webhook.py

@@ -23,6 +23,7 @@
                  Defaults to hex
 
 """
+from __future__ import annotations
 
 import asyncio
 import base64
@@ -31,11 +32,13 @@
 import json
 import logging
 import ssl
-from collections.abc import Callable
-from typing import Any
+from typing import TYPE_CHECKING, Any
 
 from aiohttp import web
 
+if TYPE_CHECKING:
+    from collections.abc import Callable
+
 logger = logging.getLogger(__name__)
 routes = web.RouteTableDef()
 
@@ -191,7 +194,7 @@ async def main(queue: asyncio.Queue, args: dict[str, Any]) -> None:
     class MockQueue:
         """A fake queue."""
 
-        async def put(self: "MockQueue", event: dict) -> None:
+        async def put(self: MockQueue, event: dict) -> None:
             """Print the event."""
             print(event)  # noqa: T201