In [1]:

    

import logging
logging.basicConfig(level=logging.DEBUG)

import pipecat.device.clock
import pipecat.limit
import pipecat.record
import pipecat.utility


    

In [2]:

    

pipe = pipecat.device.clock.metronome()
pipe = pipecat.utility.add_timestamp(pipe)
pipe = pipecat.utility.add_timestamp(pipe)
pipe = pipecat.limit.count(pipe, count=3)

for record in pipe:
    pipecat.record.dump(record)


    

    




WARNING:pipecat:Overwriting timestamp=2016-12-06T06:31:55.205017+00:00 with timestamp=2016-12-06T06:31:55.205028+00:00






    




timestamp: 2016-12-06T06:31:55.205028+00:00







    




WARNING:pipecat:Overwriting timestamp=2016-12-06T06:31:56.210804+00:00 with timestamp=2016-12-06T06:31:56.210835+00:00






    




timestamp: 2016-12-06T06:31:56.210835+00:00







    




WARNING:pipecat:Overwriting timestamp=2016-12-06T06:31:57.215138+00:00 with timestamp=2016-12-06T06:31:57.215168+00:00
INFO:pipecat:Iteration stopped after 3 records.






    




timestamp: 2016-12-06T06:31:57.215168+00:00

In [ ]: