diff options
Diffstat (limited to 'model/bidirectional.py')
| -rw-r--r-- | model/bidirectional.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/model/bidirectional.py b/model/bidirectional.py index af3891d..483ea54 100644 --- a/model/bidirectional.py +++ b/model/bidirectional.py @@ -121,8 +121,8 @@ class Stream(object): stream = transformers.balanced_batch(stream, key='latitude', batch_size=self.config.batch_size, batch_sort_size=self.config.batch_sort_size) stream = Padding(stream, mask_sources=['latitude', 'longitude']) + stream = transformers.Select(stream, req_vars) - stream = MultiProcessing(stream) return stream |