src/services/report.py
BeforeProposed
+1−2
1414
1515def build(spark, request):
1616 frame = event_seconds(load(spark, request["events"]))
17 in_period = frame.filter(~F.col("deleted") & (F.col("eventSecond") >= request["start"]) & (F.col("eventSecond") < request["end"]))
18 current = latest_visible(in_period, request["asOf"])
17 current = latest_visible(frame, request["asOf"])
1918 selected = active_period(current, request)
2019 rows = aggregate(selected, request["windowSeconds"]).collect()
2120 windows = []