Hi Matthew,
I'm sorry I reversed my diff. This is the correct delta.
Proposed fix:
site_dict['manager_dict'] = weewx.manager.get_manager_dict(
config_dict['DataBindings'], config_dict['Databases'],
'wx_binding')
- self._queue = Queue.Queue()
- self._thread = OpenWeatherMapThread(self._queue, **site_dict)
- self._thread.start()
+ self.archive_queue = Queue.Queue()
+ self.archive_thread = OpenWeatherMapThread(self.archive_queue,
**site_dict)
+ self.archive_thread.start()
self.bind(weewx.NEW_ARCHIVE_RECORD, self.new_archive_record)
loginf("Data will be uploaded for %s" % site_dict['station_id'])
def new_archive_record(self, event):
- self._queue.put(event.record)
+ self.archive_queue.put(event.record)
Possible update:
-class OpenWeatherMap(weewx.restx.StdRESTbase):
+class OpenWeatherMap(weewx.restx.StdRESTful):
--
You received this message because you are subscribed to the Google Groups
"weewx-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
For more options, visit https://groups.google.com/d/optout.
