docs: def _splpy_all_ports_ready(callable_):
      """Call all_ports_ready for a primitive operator."""
      if hasattr(type(callable_), 'all_ports_ready'):
          try:
              return callable_.all_ports_ready()
          except:
              ei = sys.exc_info()
              if streamsx._streams._runtime._call_exit(callable_, ei):
                  return None
              raise e1[1]
      return None