Re: Python embedded block stops working after consume()

The input vector may contain more items than the scheduler is expecting you to return. Use len(output_items[0]) to determine how much to consume and return. For reference, here is the autogenerated code for a new module:

    def work(self, input_items, output_items):
        in0 = input_items[0]
        out = output_items[0]
        # <+signal processing here+>
        out[:] = in0
        return len(output_items[0])

On Wed, Oct 27, 2021 at 11:46 AM Verónica Toro Betancur <vetorobe@gmail.com> wrote:

Hi,

I've been trying to implement a sync python embedded block that processes all input_items. At the end of the work() function, I call 

output_items[0][:] = input_items[0]

self.consume_each(len(input_items[0]))

return len(input_items[0])

This works well the first time and all data is processed correctly, but then, the block stops working, i.e., it doesn't process any new upcoming data and input_items[0] is always filled with zeros.

I hope someone could help me with this.

Thanks in advance.

Best regards,
Verónica