fix indexing

rinsed-org · Nov 1, 2024 · a3ce668 · a3ce668
1 parent 9cc21f7
commit a3ce668
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/ruby_snowflake/client/threaded_in_memory_strategy.rb b/lib/ruby_snowflake/client/threaded_in_memory_strategy.rb
@@ -14,8 +14,9 @@ def self.result(statement_json_body, retreive_proc, num_threads)
             next if index == 0 # already have the first partition
             futures << [index, Concurrent::Future.execute(executor: thread_pool) { retreive_proc.call(index) }]
           end
-          .compact
           .each do |entry|
+            next if entry.nil? # 0th index
+
             index, future = entry
             if future.rejected?
               if future.reason.is_a? RubySnowflake::Error