OK,
i have a thread that looks like this:
def run(self):
time.sleep(5)
while 1:
out_commands = self.store.find(OutCommand)
for out_command in out_commands:
site = self.store.get(Site, out_command.site_id)
group = self.store.get(Group, site.group_id)
if site.status_sensor.radio_type == u'aero':
self.store.add(AeroOutbox(site.id,
out_command.command))
elif site.status_sensor.radio_type in [u'ss',
u'condensed']:
self.store.add(SerialOutbox(site.id,
out_command.command))
command = unicode("execute %s" % out_command.command)
data = '%s %s %s %s %s' % (group.name, site.site_name,
site.status_sensor.monitor,
command)
self.store.add(ControlHit(group.id, site.id, command))
self.store.remove(out_command)
logg(_dir, _pre, data)
self.store.commit()
time.sleep(.5)
when it get to the store.commit() line it warns me that out_command does not
belong to this store.
there should be no other processes accessing this table from my python
program, especially this thread.
Do store objects share a common connection to the database?
i have one thread that uses storm with the following lines
from storm import database
database.DEBUG = True
this gives me the actual queries in the terminal, but also for every other
thread.
is there a way to make DEBUG = True apply only to one thread, or only to one
store?
thanks
shawn
--
storm mailing list
[email protected]
Modify settings or unsubscribe at:
https://lists.ubuntu.com/mailman/listinfo/storm
