Commenting this test now as its timing out the github actions

Author: EmanElsaban

task_processing/plugins/kubernetes/kubernetes_pod_executor.py

@@ -1,6 +1,8 @@
 import logging
+import multiprocessing
 import queue
 import time
+from multiprocessing import JoinableQueue
 from queue import Queue
 from typing import Collection
 from typing import Optional
@@ -17,8 +19,6 @@
 from kubernetes.client import V1SecurityContext
 from kubernetes.client.exceptions import ApiException
 from pyrsistent import pmap
-import multiprocessing
-from multiprocessing import JoinableQueue
 from pyrsistent import v
 from pyrsistent.typing import PMap
 
@@ -113,7 +113,7 @@ def __init__(
         # possible to cleanly shutdown both of these.
         self.pending_events: "JoinableQueue[PodEvent]" = JoinableQueue()
         self.event_queue: "JoinableQueue[Event]" = JoinableQueue()
-        
+
         # TODO(TASKPROC-243): keep track of resourceVersion so that we can continue event processing
         # from where we left off on restarts
         self.pod_event_watch_processes = []

tests/unit/conftest.py

@@ -1,5 +1,5 @@
-import threading
 import multiprocessing
+import threading
 
 import mock
 import pytest
@@ -16,7 +16,8 @@ def mock_Thread():
     with mock.patch.object(threading, "Thread") as mock_Thread:
         yield mock_Thread
 
+
 @pytest.fixture
 def mock_Process():
-    with mock.patch.object(multiprocessing, 'Process') as mock_Process:
-        yield mock_Process
+    with mock.patch.object(multiprocessing, "Process") as mock_Process:
+        yield mock_Process

tests/unit/plugins/kubernetes/kubernetes_pod_executor_test.py

@@ -802,8 +802,8 @@ def test_process_event_enqueues_task_processing_events_no_state_transition(
     assert (
         len(k8s_executor.task_metadata[mock_pod.metadata.name].task_state_history) == 0
     )
-    
-    
+
+
 def test_pending_event_processing_loop_processes_remaining_events_after_stop(
     k8s_executor,
 ):
@@ -812,6 +812,7 @@ def test_pending_event_processing_loop_processes_remaining_events_after_stop(
     test_pod = V1Pod(
         metadata=V1ObjectMeta(
             name="test-pod",
+            namespace="task_processing_tests",
         )
         # Add other necessary attributes here
     )