diff --git a/Gemfile.lock b/Gemfile.lock index 1e80e3d52..76d754280 100644 --- a/Gemfile.lock +++ b/Gemfile.lock @@ -254,7 +254,7 @@ GEM nokogiri (1.19.2-x86_64-linux-musl) racc (~> 1.4) ostruct (0.6.2) - parallel (1.27.0) + parallel (1.28.0) parser (3.3.10.1) ast (~> 2.4.1) racc @@ -562,7 +562,7 @@ CHECKSUMS nokogiri (1.19.2-x86_64-linux-gnu) sha256=fa8feca882b73e871a9845f3817a72e9734c8e974bdc4fbad6e4bc6e8076b94f nokogiri (1.19.2-x86_64-linux-musl) sha256=93128448e61a9383a30baef041bf1f5817e22f297a1d400521e90294445069a8 ostruct (0.6.2) sha256=6d7302a299e400a2c248d6ce0dad18fc3a5714e8096facc25ffd0c54ee57cfc0 - parallel (1.27.0) sha256=4ac151e1806b755fb4e2dc2332cbf0e54f2e24ba821ff2d3dcf86bf6dc4ae130 + parallel (1.28.0) sha256=33e6de1484baf2524792d178b0913fc8eb94c628d6cfe45599ad4458c638c970 parser (3.3.10.1) sha256=06f6a725d2cd91e5e7f2b7c32ba143631e1f7c8ae2fb918fc4cebec187e6a688 pp (0.6.3) sha256=2951d514450b93ccfeb1df7d021cae0da16e0a7f95ee1e2273719669d0ab9df6 prettyprint (0.2.0) sha256=2bc9e15581a94742064a3cc8b0fb9d45aae3d03a1baa6ef80922627a0766f193 diff --git a/sorbet/rbi/gems/parallel@1.27.0.rbi b/sorbet/rbi/gems/parallel@1.28.0.rbi similarity index 62% rename from sorbet/rbi/gems/parallel@1.27.0.rbi rename to sorbet/rbi/gems/parallel@1.28.0.rbi index f70062e8b..a8a657183 100644 --- a/sorbet/rbi/gems/parallel@1.27.0.rbi +++ b/sorbet/rbi/gems/parallel@1.28.0.rbi @@ -8,115 +8,115 @@ # pkg:gem/parallel#lib/parallel/version.rb:2 module Parallel class << self - # pkg:gem/parallel#lib/parallel.rb:243 + # pkg:gem/parallel#lib/parallel.rb:254 def all?(*args, &block); end - # pkg:gem/parallel#lib/parallel.rb:238 + # pkg:gem/parallel#lib/parallel.rb:249 def any?(*args, &block); end - # pkg:gem/parallel#lib/parallel.rb:234 + # pkg:gem/parallel#lib/parallel.rb:245 def each(array, options = T.unsafe(nil), &block); end - # pkg:gem/parallel#lib/parallel.rb:248 + # pkg:gem/parallel#lib/parallel.rb:259 def each_with_index(array, options = T.unsafe(nil), &block); end - # pkg:gem/parallel#lib/parallel.rb:307 + # pkg:gem/parallel#lib/parallel.rb:318 def filter_map(*_arg0, **_arg1, &_arg2); end - # pkg:gem/parallel#lib/parallel.rb:303 + # pkg:gem/parallel#lib/parallel.rb:314 def flat_map(*_arg0, **_arg1, &_arg2); end - # pkg:gem/parallel#lib/parallel.rb:228 + # pkg:gem/parallel#lib/parallel.rb:239 def in_processes(options = T.unsafe(nil), &block); end - # pkg:gem/parallel#lib/parallel.rb:212 + # pkg:gem/parallel#lib/parallel.rb:223 def in_threads(options = T.unsafe(nil)); end - # pkg:gem/parallel#lib/parallel.rb:252 + # pkg:gem/parallel#lib/parallel.rb:263 def map(source, options = T.unsafe(nil), &block); end - # pkg:gem/parallel#lib/parallel.rb:299 + # pkg:gem/parallel#lib/parallel.rb:310 def map_with_index(array, options = T.unsafe(nil), &block); end # Number of physical processor cores on the current system. # - # pkg:gem/parallel#lib/parallel.rb:312 + # pkg:gem/parallel#lib/parallel.rb:323 def physical_processor_count; end # Number of processors seen by the OS or value considering CPU quota if the process is inside a cgroup, # used for process scheduling # - # pkg:gem/parallel#lib/parallel.rb:342 + # pkg:gem/parallel#lib/parallel.rb:353 def processor_count; end - # pkg:gem/parallel#lib/parallel.rb:346 + # pkg:gem/parallel#lib/parallel.rb:357 def worker_number; end # TODO: this does not work when doing threads in forks, so should remove and yield the number instead if needed # - # pkg:gem/parallel#lib/parallel.rb:351 + # pkg:gem/parallel#lib/parallel.rb:362 def worker_number=(worker_num); end private - # pkg:gem/parallel#lib/parallel.rb:384 + # pkg:gem/parallel#lib/parallel.rb:395 def add_progress_bar!(job_factory, options); end - # pkg:gem/parallel#lib/parallel.rb:699 + # pkg:gem/parallel#lib/parallel.rb:710 def available_processor_count; end - # pkg:gem/parallel#lib/parallel.rb:647 + # pkg:gem/parallel#lib/parallel.rb:658 def call_with_index(item, index, options, &block); end - # pkg:gem/parallel#lib/parallel.rb:579 + # pkg:gem/parallel#lib/parallel.rb:590 def create_workers(job_factory, options, &block); end # options is either a Integer or a Hash with :count # - # pkg:gem/parallel#lib/parallel.rb:637 + # pkg:gem/parallel#lib/parallel.rb:648 def extract_count_from_options(options); end - # pkg:gem/parallel#lib/parallel.rb:665 + # pkg:gem/parallel#lib/parallel.rb:676 def instrument_finish(item, index, result, options); end # yield results in the order of the input items # needs to use `options` to store state between executions # needs to use `done` index since a nil result would also be valid # - # pkg:gem/parallel#lib/parallel.rb:674 + # pkg:gem/parallel#lib/parallel.rb:685 def instrument_finish_in_order(item, index, result, options); end - # pkg:gem/parallel#lib/parallel.rb:694 + # pkg:gem/parallel#lib/parallel.rb:705 def instrument_start(item, index, options); end - # pkg:gem/parallel#lib/parallel.rb:357 + # pkg:gem/parallel#lib/parallel.rb:368 def physical_processor_count_windows; end - # pkg:gem/parallel#lib/parallel.rb:613 + # pkg:gem/parallel#lib/parallel.rb:624 def process_incoming_jobs(read, write, job_factory, options, &block); end - # pkg:gem/parallel#lib/parallel.rb:567 + # pkg:gem/parallel#lib/parallel.rb:578 def replace_worker(job_factory, workers, index, options, blk); end - # pkg:gem/parallel#lib/parallel.rb:378 + # pkg:gem/parallel#lib/parallel.rb:389 def run(command); end - # pkg:gem/parallel#lib/parallel.rb:658 + # pkg:gem/parallel#lib/parallel.rb:669 def with_instrumentation(item, index, options); end - # pkg:gem/parallel#lib/parallel.rb:409 + # pkg:gem/parallel#lib/parallel.rb:420 def work_direct(job_factory, options, &block); end - # pkg:gem/parallel#lib/parallel.rb:519 + # pkg:gem/parallel#lib/parallel.rb:530 def work_in_processes(job_factory, options, &blk); end - # pkg:gem/parallel#lib/parallel.rb:453 + # pkg:gem/parallel#lib/parallel.rb:464 def work_in_ractors(job_factory, options); end - # pkg:gem/parallel#lib/parallel.rb:428 + # pkg:gem/parallel#lib/parallel.rb:439 def work_in_threads(job_factory, options, &block); end - # pkg:gem/parallel#lib/parallel.rb:587 + # pkg:gem/parallel#lib/parallel.rb:598 def worker(job_factory, options, &block); end end end @@ -126,90 +126,103 @@ class Parallel::Break < ::StandardError # pkg:gem/parallel#lib/parallel.rb:14 def initialize(value = T.unsafe(nil)); end + # marshal_dump that is used for ruby exceptions + # avoid dumping the cause since nobody needs that and it can include undumpable exceptions + # + # pkg:gem/parallel#lib/parallel.rb:21 + def _dump(_depth); end + # pkg:gem/parallel#lib/parallel.rb:12 def value; end + + class << self + # marshal_load that is used for ruby exceptions + # + # pkg:gem/parallel#lib/parallel.rb:26 + def _load(data); end + end end # pkg:gem/parallel#lib/parallel.rb:8 class Parallel::DeadWorker < ::StandardError; end -# pkg:gem/parallel#lib/parallel.rb:32 +# pkg:gem/parallel#lib/parallel.rb:43 class Parallel::ExceptionWrapper - # pkg:gem/parallel#lib/parallel.rb:35 + # pkg:gem/parallel#lib/parallel.rb:46 def initialize(exception); end - # pkg:gem/parallel#lib/parallel.rb:33 + # pkg:gem/parallel#lib/parallel.rb:44 def exception; end end -# pkg:gem/parallel#lib/parallel.rb:98 +# pkg:gem/parallel#lib/parallel.rb:109 class Parallel::JobFactory - # pkg:gem/parallel#lib/parallel.rb:99 + # pkg:gem/parallel#lib/parallel.rb:110 def initialize(source, mutex); end - # pkg:gem/parallel#lib/parallel.rb:107 + # pkg:gem/parallel#lib/parallel.rb:118 def next; end # generate item that is sent to workers # just index is faster + less likely to blow up with unserializable errors # - # pkg:gem/parallel#lib/parallel.rb:136 + # pkg:gem/parallel#lib/parallel.rb:147 def pack(item, index); end - # pkg:gem/parallel#lib/parallel.rb:126 + # pkg:gem/parallel#lib/parallel.rb:137 def size; end # unpack item that is sent to workers # - # pkg:gem/parallel#lib/parallel.rb:141 + # pkg:gem/parallel#lib/parallel.rb:152 def unpack(data); end private - # pkg:gem/parallel#lib/parallel.rb:147 + # pkg:gem/parallel#lib/parallel.rb:158 def producer?; end - # pkg:gem/parallel#lib/parallel.rb:151 + # pkg:gem/parallel#lib/parallel.rb:162 def queue_wrapper(array); end end -# pkg:gem/parallel#lib/parallel.rb:20 +# pkg:gem/parallel#lib/parallel.rb:31 class Parallel::Kill < ::Parallel::Break; end # pkg:gem/parallel#lib/parallel.rb:6 Parallel::Stop = T.let(T.unsafe(nil), Object) -# pkg:gem/parallel#lib/parallel.rb:23 +# pkg:gem/parallel#lib/parallel.rb:34 class Parallel::UndumpableException < ::StandardError - # pkg:gem/parallel#lib/parallel.rb:26 + # pkg:gem/parallel#lib/parallel.rb:37 def initialize(original); end - # pkg:gem/parallel#lib/parallel.rb:24 + # pkg:gem/parallel#lib/parallel.rb:35 def backtrace; end end -# pkg:gem/parallel#lib/parallel.rb:156 +# pkg:gem/parallel#lib/parallel.rb:167 class Parallel::UserInterruptHandler class << self - # pkg:gem/parallel#lib/parallel.rb:181 + # pkg:gem/parallel#lib/parallel.rb:192 def kill(thing); end # kill all these pids or threads if user presses Ctrl+c # - # pkg:gem/parallel#lib/parallel.rb:161 + # pkg:gem/parallel#lib/parallel.rb:172 def kill_on_ctrl_c(pids, options); end private - # pkg:gem/parallel#lib/parallel.rb:205 + # pkg:gem/parallel#lib/parallel.rb:216 def restore_interrupt(old, signal); end - # pkg:gem/parallel#lib/parallel.rb:190 + # pkg:gem/parallel#lib/parallel.rb:201 def trap_interrupt(signal); end end end -# pkg:gem/parallel#lib/parallel.rb:157 +# pkg:gem/parallel#lib/parallel.rb:168 Parallel::UserInterruptHandler::INTERRUPT_SIGNAL = T.let(T.unsafe(nil), Symbol) # pkg:gem/parallel#lib/parallel/version.rb:3 @@ -218,40 +231,40 @@ Parallel::VERSION = T.let(T.unsafe(nil), String) # pkg:gem/parallel#lib/parallel/version.rb:3 Parallel::Version = T.let(T.unsafe(nil), String) -# pkg:gem/parallel#lib/parallel.rb:51 +# pkg:gem/parallel#lib/parallel.rb:62 class Parallel::Worker - # pkg:gem/parallel#lib/parallel.rb:55 + # pkg:gem/parallel#lib/parallel.rb:66 def initialize(read, write, pid); end # might be passed to started_processes and simultaneously closed by another thread # when running in isolation mode, so we have to check if it is closed before closing # - # pkg:gem/parallel#lib/parallel.rb:68 + # pkg:gem/parallel#lib/parallel.rb:79 def close_pipes; end - # pkg:gem/parallel#lib/parallel.rb:52 + # pkg:gem/parallel#lib/parallel.rb:63 def pid; end - # pkg:gem/parallel#lib/parallel.rb:52 + # pkg:gem/parallel#lib/parallel.rb:63 def read; end - # pkg:gem/parallel#lib/parallel.rb:61 + # pkg:gem/parallel#lib/parallel.rb:72 def stop; end - # pkg:gem/parallel#lib/parallel.rb:53 + # pkg:gem/parallel#lib/parallel.rb:64 def thread; end - # pkg:gem/parallel#lib/parallel.rb:53 + # pkg:gem/parallel#lib/parallel.rb:64 def thread=(_arg0); end - # pkg:gem/parallel#lib/parallel.rb:73 + # pkg:gem/parallel#lib/parallel.rb:84 def work(data); end - # pkg:gem/parallel#lib/parallel.rb:52 + # pkg:gem/parallel#lib/parallel.rb:63 def write; end private - # pkg:gem/parallel#lib/parallel.rb:91 + # pkg:gem/parallel#lib/parallel.rb:102 def wait; end end