File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -204,15 +204,7 @@ namespace hgraph
204204 }
205205
206206 bool TimeSeriesWindowInput::all_valid () const {
207- if (!valid ()) return false ;
208- if (auto *f = as_fixed_output ()) return f->len () >= f->min_size ();
209- if (auto *t = as_time_output ()) {
210- // For time windows, check if enough time has passed
211- auto elapsed =
212- owning_graph ()->evaluation_time () - owning_graph ()->evaluation_engine_api ()->start_time ();
213- return elapsed >= t->min_size ();
214- }
215- return false ;
207+ return output () != nullptr && output ()->all_valid ();
216208 }
217209
218210 nb::object TimeSeriesWindowInput::py_value_times () const {
@@ -314,8 +306,6 @@ namespace hgraph
314306 }
315307
316308 _roll ();
317- if (_buffer.empty ()) return nb::none ();
318-
319309 // Convert deque to Python list
320310 nb::list result;
321311 for (const auto & v : _buffer) {
@@ -374,7 +364,6 @@ namespace hgraph
374364
375365 nb::object TimeSeriesTimeWindowOutput::py_value_times () const {
376366 _roll ();
377- if (_times.empty ()) return nb::none ();
378367 std::vector<engine_time_t > out (_times.begin (), _times.end ());
379368 return nb::cast (out);
380369 }
You can’t perform that action at this time.
0 commit comments