def _submit(self, params):
        main_stream = self.query_engine.get('geo_widget', params)
        lookup_stream = self.query_engine.get('geo_lookup', params, cache_ttl=1)
        combined = self.transformers.combine(main_stream, lookup_stream, left_on=['user_id'], right_on=['user_id'])
        aggregated = self.transformers.aggregate(combined, group_by=['country'], operators={'revenue': 'sum', 'spend': 'sum'})
        aggregated['ROI'] = aggregated.revenue/(aggregated.spend+aggregated.revenue)
        return aggregated
Extract from a zip file, with an optional filter
dataset/ETHPy150Open Convertro/Hydro/src/sample/geo_queries/geo_widget_topology.py/GeoWidgetTopology._submit--crossover with--dataset/ETHPy150Open pantsbuild/pants/src/python/pants/fs/archive.py/ZipArchiver.extract