fix: panic by upstream not found

[laysakura]

Fixes: #80

input_queue() takes task_id and upstream parameters.

These parameters come from different threads:

• task_id is from GenericWorkerThread
• upstream is from main thread (when creating CollectSubtask)

These threads may observe different PipelineVersion.

[codecov]

Codecov Report

Merging #86 (34ac2f4) into main (848028c) will decrease coverage by 0.01%.
The diff coverage is 90.00%.

@@            Coverage Diff             @@
##             main      #86      +/-   ##
==========================================
- Coverage   83.70%   83.68%   -0.02%     
==========================================
  Files         198      198              
  Lines       11769    11770       +1     
==========================================
- Hits         9851     9850       -1     
- Misses       1918     1920       +2     

Impacted Files	Coverage Δ
...tream_engine/autonomous_executor/task/sink_task.rs	96.20% <75.00%> (-1.24%)	⬇️
...task/pump_subtask/query_subtask/collect_subtask.rs	98.46% <100.00%> (+0.02%)	⬆️
...rc/stream_engine/autonomous_executor/task_graph.rs	99.43% <100.00%> (-0.01%)	⬇️
...omous_executor/row/value/sql_value/nn_sql_value.rs	66.48% <0.00%> (-0.55%)	⬇️
...ngql-core/tests/feat_performance_metrics_report.rs	99.34% <0.00%> (ø)

---

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 848028c...34ac2f4. Read the comment docs.