ruff format

Author: fabioz

_pydev_runfiles/pydev_runfiles_xml_rpc.py

@@ -203,7 +203,7 @@ def _encode_if_needed(obj):
 
     elif isinstance(obj, bytes):
         try:
-            return xmlrpclib.Binary(obj.decode(sys.stdin.encoding, 'replace').encode("ISO-8859-1", "xmlcharrefreplace"))
+            return xmlrpclib.Binary(obj.decode(sys.stdin.encoding, "replace").encode("ISO-8859-1", "xmlcharrefreplace"))
         except:
             return xmlrpclib.Binary(obj)  # bytes already
 

_pydevd_bundle/_debug_adapter/__main__pydevd_gen_debug_adapter_protocol.py

@@ -458,7 +458,9 @@ def update_class_to_generate_init(class_to_generate):
     # Note: added kwargs because some messages are expected to be extended by the user (so, we'll actually
     # make all extendable so that we don't have to worry about which ones -- we loose a little on typing,
     # but may be better than doing a allow list based on something only pointed out in the documentation).
-    class_to_generate["init"] = '''def __init__(self%(args)s, update_ids_from_dap=False, **kwargs):  # noqa (update_ids_from_dap may be unused)
+    class_to_generate[
+        "init"
+    ] = '''def __init__(self%(args)s, update_ids_from_dap=False, **kwargs):  # noqa (update_ids_from_dap may be unused)
     """
 %(docstring)s
     """

_pydevd_bundle/pydevd_code_to_source.py

@@ -15,7 +15,6 @@
 
 
 class _Stack(object):
-
     def __init__(self):
         self._contents = []
 
@@ -35,7 +34,6 @@ def pop(self):
 
 
 class _Token(object):
-
     def __init__(self, i_line, instruction=None, tok=_SENTINEL, priority=0, after=None, end_of_line=False):
         """
         :param i_line:
@@ -87,7 +85,6 @@ def __repr__(self):
 
 
 class _Writer(object):
-
     def __init__(self):
         self.line_to_contents = {}
         self.all_tokens = set()
@@ -114,7 +111,6 @@ def write(self, line, token):
 
 
 class _BaseHandler(object):
-
     def __init__(self, i_line, instruction, stack, writer, disassembler):
         self.i_line = i_line
         self.instruction = instruction
@@ -149,13 +145,11 @@ def _register(cls):
 
 
 class _BasePushHandler(_BaseHandler):
-
     def _handle(self):
         self.stack.push(self)
 
 
 class _BaseLoadHandler(_BasePushHandler):
-
     def _handle(self):
         _BasePushHandler._handle(self)
         self.tokens = [_Token(self.i_line, self.instruction)]
@@ -503,7 +497,6 @@ def _compose_line_contents(line_contents, previous_line_tokens):
 
 
 class _PyCodeToSource(object):
-
     def __init__(self, co, memo=None):
         if memo is None:
             memo = {}
@@ -593,7 +586,7 @@ def disassemble(self):
                 stream.write("%s\n" % s)
 
             if dedents_found:
-                indent = indent[:-(4 * dedents_found)]
+                indent = indent[: -(4 * dedents_found)]
             last_line = i_line
 
         return stream.getvalue()

_pydevd_bundle/pydevd_collect_bytecode_info.py

@@ -10,7 +10,6 @@
 
 
 class TryExceptInfo(object):
-
     def __init__(self, try_line, ignore=False):
         """
         :param try_line:
@@ -54,7 +53,6 @@ def __str__(self):
 
 
 class ReturnInfo(object):
-
     def __init__(self, return_line):
         self.return_line = return_line
 
@@ -119,7 +117,6 @@ def collect_return_info(co, use_func_first_line=False):
 if sys.version_info[:2] <= (3, 9):
 
     class _TargetInfo(object):
-
         def __init__(self, except_end_instruction, jump_if_not_exc_instruction=None):
             self.except_end_instruction = except_end_instruction
             self.jump_if_not_exc_instruction = jump_if_not_exc_instruction
@@ -138,7 +135,7 @@ def __str__(self):
 
     def _get_except_target_info(instructions, exception_end_instruction_index, offset_to_instruction_idx):
         next_3 = [
-            j_instruction.opname for j_instruction in instructions[exception_end_instruction_index: exception_end_instruction_index + 3]
+            j_instruction.opname for j_instruction in instructions[exception_end_instruction_index : exception_end_instruction_index + 3]
         ]
         # print('next_3:', [(j_instruction.opname, j_instruction.argval) for j_instruction in instructions[exception_end_instruction_index:exception_end_instruction_index + 3]])
         if next_3 == ["POP_TOP", "POP_TOP", "POP_TOP"]:  # try..except without checking exception.
@@ -178,7 +175,7 @@ def _get_except_target_info(instructions, exception_end_instruction_index, offse
                 return _TargetInfo(except_end_instruction)
 
         elif next_3 and next_3[0] == "DUP_TOP":  # try..except AssertionError.
-            iter_in = instructions[exception_end_instruction_index + 1:]
+            iter_in = instructions[exception_end_instruction_index + 1 :]
             for j, jump_if_not_exc_instruction in enumerate(iter_in):
                 if jump_if_not_exc_instruction.opname == "JUMP_IF_NOT_EXC_MATCH":
                     # Python 3.9
@@ -213,7 +210,7 @@ def collect_try_except_info(co, use_func_first_line=False):
 
         try_except_info_lst = []
 
-        op_offset_to_line = dict((k, v)  for (k, v) in dis.findlinestarts(co) if v is not None)
+        op_offset_to_line = dict((k, v) for (k, v) in dis.findlinestarts(co) if v is not None)
 
         offset_to_instruction_idx = {}
 
@@ -262,7 +259,7 @@ def collect_try_except_info(co, use_func_first_line=False):
                     try_except_info.except_end_line = _get_line(op_offset_to_line, except_end_instruction.offset, firstlineno, search=True)
                     try_except_info_lst.append(try_except_info)
 
-                    for raise_instruction in instructions[i: offset_to_instruction_idx[try_except_info.except_end_bytecode_offset]]:
+                    for raise_instruction in instructions[i : offset_to_instruction_idx[try_except_info.except_end_bytecode_offset]]:
                         if raise_instruction.opname == "RAISE_VARARGS":
                             if raise_instruction.argval == 0:
                                 try_except_info.raise_lines_in_except.append(
@@ -274,7 +271,6 @@ def collect_try_except_info(co, use_func_first_line=False):
 elif sys.version_info[:2] == (3, 10):
 
     class _TargetInfo(object):
-
         def __init__(self, except_end_instruction, jump_if_not_exc_instruction=None):
             self.except_end_instruction = except_end_instruction
             self.jump_if_not_exc_instruction = jump_if_not_exc_instruction
@@ -293,21 +289,21 @@ def __str__(self):
 
     def _get_except_target_info(instructions, exception_end_instruction_index, offset_to_instruction_idx):
         next_3 = [
-            j_instruction.opname for j_instruction in instructions[exception_end_instruction_index: exception_end_instruction_index + 3]
+            j_instruction.opname for j_instruction in instructions[exception_end_instruction_index : exception_end_instruction_index + 3]
         ]
         # print('next_3:', [(j_instruction.opname, j_instruction.argval) for j_instruction in instructions[exception_end_instruction_index:exception_end_instruction_index + 3]])
         if next_3 == ["POP_TOP", "POP_TOP", "POP_TOP"]:  # try..except without checking exception.
             # Previously there was a jump which was able to point where the exception would end. This
             # is no longer true, now a bare except doesn't really have any indication in the bytecode
             # where the end would be expected if the exception wasn't raised, so, we just blindly
             # search for a POP_EXCEPT from the current position.
-            for pop_except_instruction in instructions[exception_end_instruction_index + 3:]:
+            for pop_except_instruction in instructions[exception_end_instruction_index + 3 :]:
                 if pop_except_instruction.opname == "POP_EXCEPT":
                     except_end_instruction = pop_except_instruction
                     return _TargetInfo(except_end_instruction)
 
         elif next_3 and next_3[0] == "DUP_TOP":  # try..except AssertionError.
-            iter_in = instructions[exception_end_instruction_index + 1:]
+            iter_in = instructions[exception_end_instruction_index + 1 :]
             for jump_if_not_exc_instruction in iter_in:
                 if jump_if_not_exc_instruction.opname == "JUMP_IF_NOT_EXC_MATCH":
                     # Python 3.9
@@ -332,7 +328,7 @@ def collect_try_except_info(co, use_func_first_line=False):
 
         try_except_info_lst = []
 
-        op_offset_to_line = dict((k, v)  for (k, v) in dis.findlinestarts(co) if v is not None)
+        op_offset_to_line = dict((k, v) for (k, v) in dis.findlinestarts(co) if v is not None)
 
         offset_to_instruction_idx = {}
 
@@ -386,15 +382,15 @@ def collect_try_except_info(co, use_func_first_line=False):
                     except_end_line = -1
                     start_i = offset_to_instruction_idx[try_except_info.except_bytecode_offset]
                     end_i = offset_to_instruction_idx[except_end_instruction.offset]
-                    for instruction in instructions[start_i: end_i + 1]:
+                    for instruction in instructions[start_i : end_i + 1]:
                         found_at_line = op_offset_to_line.get(instruction.offset)
                         if found_at_line is not None and found_at_line > except_end_line:
                             except_end_line = found_at_line
                     try_except_info.except_end_line = except_end_line - firstlineno
 
                     try_except_info_lst.append(try_except_info)
 
-                    for raise_instruction in instructions[i: offset_to_instruction_idx[try_except_info.except_end_bytecode_offset]]:
+                    for raise_instruction in instructions[i : offset_to_instruction_idx[try_except_info.except_end_bytecode_offset]]:
                         if raise_instruction.opname == "RAISE_VARARGS":
                             if raise_instruction.argval == 0:
                                 try_except_info.raise_lines_in_except.append(
@@ -413,11 +409,11 @@ def collect_try_except_info(co, use_func_first_line=False):
         """
         return []
 
+
 import ast as ast_module
 
 
 class _Visitor(ast_module.NodeVisitor):
-
     def __init__(self):
         self.try_except_infos = []
         self._stack = []
@@ -489,7 +485,6 @@ def collect_try_except_info_from_contents(contents, filename="<unknown>"):
 
 
 class _MsgPart(object):
-
     def __init__(self, line, tok):
         assert line >= 0
         self.line = line
@@ -528,13 +523,12 @@ def add_to_line_to_contents(cls, obj, line_to_contents, line=None):
 
 
 class _Disassembler(object):
-
     def __init__(self, co, firstlineno, level=0):
         self.co = co
         self.firstlineno = firstlineno
         self.level = level
         self.instructions = list(iter_instructions(co))
-        op_offset_to_line = self.op_offset_to_line = dict((k, v)  for (k, v) in dis.findlinestarts(co) if v is not None)
+        op_offset_to_line = self.op_offset_to_line = dict((k, v) for (k, v) in dis.findlinestarts(co) if v is not None)
 
         # Update offsets so that all offsets have the line index (and update it based on
         # the passed firstlineno).
@@ -671,7 +665,7 @@ def _lookahead(self):
                 else:
                     return None  # This is odd
 
-            del self.instructions[delta: delta + next_instruction.argval + 1]  # +1 = BUILD_TUPLE
+            del self.instructions[delta : delta + next_instruction.argval + 1]  # +1 = BUILD_TUPLE
 
             found = iter(found[delta:])
 

_pydevd_bundle/pydevd_comm.py

@@ -328,7 +328,6 @@ def process_command(self, cmd_id, seq, text):
 
 
 class FSNotifyThread(PyDBDaemonThread):
-
     def __init__(self, py_db, api, watch_dirs):
         PyDBDaemonThread.__init__(self, py_db)
         self.api = api
@@ -577,7 +576,6 @@ def __str__(self):
 
 
 class InternalThreadCommandForAnyThread(InternalThreadCommand):
-
     def __init__(self, thread_id, method=None, *args, **kwargs):
         assert thread_id == "*"
 
@@ -744,7 +742,6 @@ def internal_smart_step_into(py_db, thread_id, offset, child_offset, set_additio
 
 
 class InternalSetNextStatementThread(InternalThreadCommand):
-
     def __init__(self, thread_id, cmd_id, line, func_name, seq=0):
         """
         cmd_id may actually be one of:
@@ -861,7 +858,6 @@ def do_it(self, dbg):
 
 
 class InternalGetArray(InternalThreadCommand):
-
     def __init__(self, seq, roffset, coffset, rows, cols, format, thread_id, frame_id, scope, attrs):
         self.sequence = seq
         self.thread_id = thread_id
@@ -1264,10 +1260,10 @@ def __create_frame():
         safe_repr_custom_attrs = {}
         if context == "clipboard":
             safe_repr_custom_attrs = dict(
-                maxstring_outer=2 ** 64,
-                maxstring_inner=2 ** 64,
-                maxother_outer=2 ** 64,
-                maxother_inner=2 ** 64,
+                maxstring_outer=2**64,
+                maxstring_inner=2**64,
+                maxother_outer=2**64,
+                maxother_inner=2**64,
             )
 
         if context == "repl" and eval_result is None:
@@ -1348,9 +1344,8 @@ def internal_evaluate_expression(dbg, seq, thread_id, frame_id, expression, is_e
 
 
 def _set_expression_response(py_db, request, error_message):
-    body = pydevd_schema.SetExpressionResponseBody(value='')
-    variables_response = pydevd_base_schema.build_response(request, kwargs={
-        'body':body, 'success':False, 'message': error_message})
+    body = pydevd_schema.SetExpressionResponseBody(value="")
+    variables_response = pydevd_base_schema.build_response(request, kwargs={"body": body, "success": False, "message": error_message})
     py_db.writer.add_command(NetCommand(CMD_RETURN, 0, variables_response, is_json=True))
 
 
@@ -1366,18 +1361,18 @@ def internal_set_expression_json(py_db, request, thread_id):
         fmt = fmt.to_dict()
 
     frame = py_db.find_frame(thread_id, frame_id)
-    exec_code = '%s = (%s)' % (expression, value)
+    exec_code = "%s = (%s)" % (expression, value)
     try:
         pydevd_vars.evaluate_expression(py_db, frame, exec_code, is_exec=True)
     except (Exception, KeyboardInterrupt):
-        _set_expression_response(py_db, request, error_message='Error executing: %s' % (exec_code,))
+        _set_expression_response(py_db, request, error_message="Error executing: %s" % (exec_code,))
         return
 
     # Ok, we have the result (could be an error), let's put it into the saved variables.
     frame_tracker = py_db.suspended_frames_manager.get_frame_tracker(thread_id)
     if frame_tracker is None:
         # This is not really expected.
-        _set_expression_response(py_db, request, error_message='Thread id: %s is not current thread id.' % (thread_id,))
+        _set_expression_response(py_db, request, error_message="Thread id: %s is not current thread id." % (thread_id,))
         return
 
     # Now that the exec is done, get the actual value changed to return.

_pydevd_bundle/pydevd_daemon_thread.py

@@ -101,7 +101,7 @@ def _patch_threading_to_hide_pydevd_threads():
         {"_active_limbo_lock", "_limbo", "_active", "values", "list"},
         {"_active_limbo_lock", "_limbo", "_active", "values", "NULL + list"},
         {"NULL + list", "_active", "_active_limbo_lock", "NULL|self + values", "_limbo"},
-        {'_active_limbo_lock', 'values + NULL|self', '_limbo', '_active', 'list + NULL'},
+        {"_active_limbo_lock", "values + NULL|self", "_limbo", "_active", "list + NULL"},
     ):
         pydev_log.debug("Applying patching to hide pydevd threads (Py3 version).")
 

_pydevd_bundle/pydevd_frame.py

@@ -25,6 +25,7 @@
     def get_smart_step_into_variant_from_frame_offset(*args, **kwargs):
         return None
 
+
 # IFDEF CYTHON
 # cython_inline_constant: CMD_STEP_INTO = 107
 # cython_inline_constant: CMD_STEP_INTO_MY_CODE = 144
@@ -123,6 +124,7 @@ class _TryExceptContainerObj(object):
 
     try_except_infos = None
 
+
 # ENDIF
 
 

_pydevd_bundle/pydevd_save_locals.py

@@ -124,7 +124,7 @@ def update_globals_and_locals(updated_globals, initial_globals, frame):
                     if key in f_locals:
                         f_locals[key] = None
                 except Exception as e:
-                    pydev_log.info('Unable to remove key: %s from locals. Exception: %s', key, e)
+                    pydev_log.info("Unable to remove key: %s from locals. Exception: %s", key, e)
 
     if f_locals is not None:
         save_locals(frame)

_pydevd_bundle/pydevd_trace_dispatch_regular.py

@@ -187,9 +187,7 @@ def fix_top_level_trace_and_get_trace_func(py_db, frame):
             if top_level_thread_tracer is None:
                 # Stop in some internal place to report about unhandled exceptions
                 top_level_thread_tracer = TopLevelThreadTracerOnlyUnhandledExceptions(args)
-                additional_info.top_level_thread_tracer_unhandled = (
-                    top_level_thread_tracer
-                )  # Hack for cython to keep it alive while the thread is alive (just the method in the SetTrace is not enough).
+                additional_info.top_level_thread_tracer_unhandled = top_level_thread_tracer  # Hack for cython to keep it alive while the thread is alive (just the method in the SetTrace is not enough).
 
         # print(' --> found to trace unhandled', f_unhandled.f_code.co_name, f_unhandled.f_code.co_filename, f_unhandled.f_code.co_firstlineno)
         f_trace = top_level_thread_tracer.get_trace_dispatch_func()

_pydevd_frame_eval/vendored/bytecode/concrete.py

@@ -119,7 +119,6 @@ def disassemble(cls, lineno, code, offset):
 
 
 class ConcreteBytecode(_bytecode._BaseBytecodeList):
-
     def __init__(self, instructions=(), *, consts=(), names=(), varnames=()):
         super().__init__()
         self.consts = list(consts)
@@ -169,7 +168,7 @@ def __eq__(self, other):
 
     @staticmethod
     def from_code(code, *, extended_arg=False):
-        line_starts = dict((k, v)  for (k, v) in dis.findlinestarts(code) if v is not None)
+        line_starts = dict((k, v) for (k, v) in dis.findlinestarts(code) if v is not None)
 
         # find block starts
         instructions = []