Don't import asyncio early to avoid importing multiprocessing.

src/debugpy/_vendored/pydevd/pydevd_concurrency_analyser/pydevd_concurrency_logger.py

@@ -9,6 +9,7 @@
 from pydevd_concurrency_analyser.pydevd_thread_wrappers import ObjectWrapper, wrap_attr
 import pydevd_file_utils
 from _pydev_bundle import pydev_log
+import sys
 
 file_system_encoding = getfilesystemencoding()
 
@@ -29,11 +30,6 @@
 # return time since epoch in milliseconds
 cur_time = lambda: int(round(time.time() * 1000000))
 
-try:
-    import asyncio  # @UnresolvedImport
-except:
-    pass
-
 
 def get_text_list_for_frame(frame):
     # partial copy-paste from make_thread_suspend_str
@@ -255,6 +251,12 @@ def __init__(self):
         self.start_time = cur_time()
 
     def get_task_id(self, frame):
+        asyncio = sys.modules.get('asyncio')
+        if asyncio is None:
+            # If asyncio was not imported, there's nothing to be done
+            # (also fixes issue where multiprocessing is imported due
+            # to asyncio).
+            return None
         while frame is not None:
             if "self" in frame.f_locals:
                 self_obj = frame.f_locals["self"]
@@ -275,6 +277,14 @@ def log_event(self, frame):
 
         if not hasattr(frame, "f_back") or frame.f_back is None:
             return
+
+        asyncio = sys.modules.get('asyncio')
+        if asyncio is None:
+            # If asyncio was not imported, there's nothing to be done
+            # (also fixes issue where multiprocessing is imported due
+            # to asyncio).
+            return
+
         back = frame.f_back
 
         if "self" in frame.f_locals:

src/debugpy/_vendored/pydevd/tests_python/resources/_debugger_case_multiprocessing_2.py

@@ -0,0 +1,20 @@
+from multiprocessing import Process, Queue
+
+
+class Foo:
+
+    def __init__(self, value):
+        self.value = value  # break 2 here
+
+
+def f(q):
+    q.put(Foo(1))
+
+
+if __name__ == '__main__':
+    q = Queue()
+    p = Process(target=f, args=(q,))
+    p.start()
+    print(q.get().value)  # break 1 here
+    print('TEST SUCEEDED!')
+    p.join()

src/debugpy/_vendored/pydevd/tests_python/test_debugger.py

@@ -2368,6 +2368,7 @@ def get_environ(writer):
 
 @pytest.mark.skipif(not IS_CPYTHON, reason='CPython only test.')
 @pytest.mark.parametrize('file_to_check', [
+    '_debugger_case_multiprocessing_2.py',
     '_debugger_case_multiprocessing.py',
     '_debugger_case_python_c.py',
     '_debugger_case_multiprocessing_pool.py'