| Index: trunk/analytics/pipeliner/user_agent.py |
| — | — | @@ -61,7 +61,7 @@ |
| 62 | 62 | This class does all the heavy lifting of aggregating observations, writing output |
| 63 | 63 | to a file, and do some simple logging |
| 64 | 64 | ''' |
| 65 | | - def __init__(self, observation_class, filename, process_id, number_of_fields=14): |
| | 65 | + def __init__(self, observation_class, filename, process_id): |
| 66 | 66 | self.start = datetime.now() |
| 67 | 67 | self.skipped_records = 0 |
| 68 | 68 | self.http_valid_codes = {'200':1,'304':1, '302':1} |
| — | — | @@ -72,7 +72,7 @@ |
| 73 | 73 | self.url = None |
| 74 | 74 | self.filename = filename |
| 75 | 75 | self.process_id = process_id |
| 76 | | - self.number_of_fields = number_of_fields |
| | 76 | + self.number_of_fields = 14 |
| 77 | 77 | self.observation_class = observation_class |
| 78 | 78 | self.gi = GeoIP.new(GeoIP.GEOIP_MEMORY_CACHE) |
| 79 | 79 | self.error_vars = ['http_invalid_codes', 'invalid_user_agents', 'skipped_records'] |
| — | — | @@ -275,7 +275,7 @@ |
| 276 | 276 | |
| 277 | 277 | |
| 278 | 278 | def debug(): |
| 279 | | - pipeline = UserAgentPipeline(UserAgentObservation, 'mobile.log-20110826.gz', 0, 14) |
| | 279 | + pipeline = UserAgentPipeline(UserAgentObservation, 'mobile.log-20110826.gz', 0) |
| 280 | 280 | pipeline.run() |
| 281 | 281 | |
| 282 | 282 | if __name__ == '__main__': |