code: def all_tasks(loop=None):
      """Return a set of all tasks for the loop."""
      if loop is None:
          loop = events.get_running_loop()
      # Looping over a WeakSet (_all_tasks) isn't safe as it can be updated from another
      # thread while we do so. Therefore we cast it to list prior to filtering. The list
      # cast itself requires iteration, so we repeat it several times ignoring
      # RuntimeErrors (which are not very likely to occur). See issues 34970 and 36607 for
      # details.
      i = 0
      while True:
          try:
              tasks = list(_all_tasks)
          except RuntimeError:
              i += 1
              if i >= 1000:
                  raise
          else:
              break
      return {
          t
          for t in tasks
          if futures._get_loop(t) is loop and not t.done()
      }
  
imports: import concurrent.futures
  import contextvars
  import functools
  import inspect
  import itertools
  import types
  import warnings
  import weakref
  from types import GenericAlias
  from .None import base_tasks
  from .None import coroutines
  from .None import events
  from .None import exceptions
  from .None import futures
  from .coroutines import _is_coroutine
label_desc: Use image node_id 2 for calling a global function with example usage: all_tasks(loop) and returns: unknown