PregelExecutableTask

PregelExecutableTask(
  self,
  name: str,
  input: Any,
  proc: Runnable,
  writes: deque[tuple[str, Any]],
  config: RunnableConfig,
  triggers: Sequence[str],
  retry_policy: Sequence[RetryPolicy],
  cache_key: CacheKey | None,
  id: str,
  path: tuple[str | int | tuple, ...],
  writers: Sequence[Runnable] = (),
  subgraphs: Sequence[PregelProtocol] = ()
)