def process_data_events(self, time_limit=0):
        common_terminator = lambda: bool(
            self._channels_pending_dispatch or self._ready_events)

        if time_limit is None:
            self._flush_output(common_terminator)
        else:
            with _IoloopTimerContext(time_limit, self._impl) as timer:
                self._flush_output(timer.is_ready, common_terminator)

        if self._ready_events:
            self._dispatch_connection_events()

        if self._channels_pending_dispatch:
            self._dispatch_channel_events()
Django cascades deletes through generic-related objects to their
dataset/ETHPy150Open pika/pika/pika/adapters/blocking_connection.py/BlockingConnection.process_data_events--crossover with--dataset/ETHPy150Open adieu/django-nonrel/tests/regressiontests/delete_regress/tests.py/DeleteCascadeTests.test_generic_relation_cascade