138            bad_events[idempotency_id] = str(e)
139            continue
140
141    ## Sent to Redpanda Topic142    for customer_id, events in events_by_customer.items():
143        stream_events = {"events": events, "organization_id": organization_pk}
144        kafka_producer.produce(customer_id, stream_events)

237                inner_results["revenue_by_metric"]["flat_fees"][
238                    "original_plan_revenue"
239                ] += old_usage_revenue["flat_amount_due"]
240                ## PROCESS NEW SUB241                sub.billing_plan = subst.new_plan
242                sub.save()
243                new_usage_revenue = sub.get_usage_and_revenue()

207                        "original_plan_revenue": Decimal(0),
208                        "new_plan_revenue": Decimal(0),
209                    }
210                ## PROCESS OLD SUB211                old_usage_revenue = sub.get_usage_and_revenue()
212                # cumulative revenue
213                inner_results["cumulative_revenue"][end_date][

1520        return instance
1521
1522
1523## INVOICE1524class InvoiceLineItemSerializer(serializers.ModelSerializer):
1525    class Meta:
1526        model = InvoiceLineItem

 300        return instance
 301
 302
 303## BILLABLE METRIC 304class CategoricalFilterSerializer(serializers.ModelSerializer):
 305    class Meta:
 306        model = CategoricalFilter