How to invoke Calculator Process method when optional input packet is missing

[Honya2000]

Hello,
I declare my calculator contract this way:

  static constexpr Input<GpuBuffer> kInputTick{ kTickTag };
  static constexpr Input<GpuBuffer> kInputFallback{ kFallbackTag };
  static constexpr Input<GpuBuffer>::Optional kInput{ kInputTag };
  static constexpr Output<bool> kOutputPresence{ kPresenceTag };
  static constexpr Output<GpuBuffer> kOutput{ kOutputTag };

  MEDIAPIPE_NODE_CONTRACT(kInputTick, kInputFallback, kInput, kOutputPresence, kOutput);

During graph run i'm not supplying any packet to kInput tag, because i'm checking it presence in Process method (it declared Optional).

But problem is Process metod is not called for this calculator at all which causes whole graph deadlock.
How to setup graph node to call Process method even when some optional streams are missing?

I tried everything: cc->SetProcessTimestampBounds(true), cc->SetOffset(TimestampDiff(0)).

Nothing helps. Process method is never invoke for this calculator because it waits for kInput stream.

[HarishPermal]

hi @Honya2000,

Thanks for brining this, i'll check this, in my end and i'll ping you, mean while can you share some sample reproducible code to try it in my end.

[HarishPermal]

Hi @Honya2000,

Can you try using the ImmediateInputStreamHandler on the node that uses your calculator, this lets Process() run when TICK or FALLBACK arrive, even if INPUT is missing.

input_stream_handler {
  input_stream_handler: "ImmediateInputStreamHandler"
}

[Honya2000]

Thank you for suggestion,
But i solved this by calling SetInputStreamTimestampBound for all streams which aren't provided externally.

Now i have quite different problem which i'm trying to solve 2 days without success...
There is input stream event which should be set occasionally, i declare it in calculator contract this way:

  static constexpr Input<tmrw::TmrwEvents>::Optional kInputEvents{ "INPUT_EVENTS" };
  MEDIAPIPE_NODE_CONTRACT(kInputEvents);

In graph processing i call executor_->AddPacketToInputStream when event is provided (happens quite rarely)
and call executor_->SetInputStreamTimestampBound when event is not provided

In calculator process function - i just check packet presence this way:
const tmrw::TmrwEvents* json_events = nullptr;
if (kInputEvents(cc).IsConnected() && !kInputEvents(cc).IsEmpty())
{
json_events = &kInputJsonEvents(cc).Get();
}
else
json_events = default_json_events;

But for some reason kInputEvents(cc) packet is never empty after first call of executor_->AddPacketToInputStream.
Isn't it should be empty when i use SetInputStreamTimestampBound on next frames?

I'm not sure how to solve this. I even tried to send empty packet next frame instead of SetInputStreamTimestampBound, the stream always contains the first packet which i sent using executor_->AddPacketToInputStream.

Do you have any idea how to solve this ?

[Honya2000]

Nevermind. I found the bug in my code caused by intermediate calculator processing...