EventBusDatastore.Pipeline.process_data

You're seeing just the function process_data, go back to EventBusDatastore.Pipeline module for more information.
Link to this function

process_data(event_shadow)