Merge 46f76c8 into 7b6232b

Author: evanevanevanevannnn

ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h

@@ -1757,6 +1757,9 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
                     auto inputIndex = protoSource.GetInputIndex();
                     if (auto* sourceInfoPtr = SourcesMap.FindPtr(inputIndex)) {
                         auto& sourceInfo = *sourceInfoPtr;
+                        if (!sourceInfo.AsyncInput)
+                            continue;
+
                         protoSource.SetIngressName(sourceInfo.Type);
                         const auto& ingressStats = sourceInfo.AsyncInput->GetIngressStats();
                         FillAsyncStats(*protoSource.MutableIngress(), ingressStats);