Well I never got it figured out, so I just wrote the script as a cron
job instead of using TG scheduler. Though I'd like to be able to
distribute this as an egg, so if anyone has any other suggestions on
how to get it working as a task in TG that'd be great.
Wayne
On Feb 19, 3:37 pm, "[EMAIL PROTECTED]" <[EMAIL PROTECTED]> wrote:
> I have also tried sequential method vs. forked method vs. the default
> threaded method for the processmethod of the scheduler. I have tried
> creating my own sqlobject connection with a URI and
> sqlhub.processConnection but it seems to have the same results.
>
> On Feb 19, 3:02 am, "[EMAIL PROTECTED]" <[EMAIL PROTECTED]> wrote:
>
> > Still wrestling with this, anyone have any suggestions of somethings I
> > should maybe try?
>
> > Thanks.
>
> > On Feb 17, 4:17 am, "[EMAIL PROTECTED]" <[EMAIL PROTECTED]> wrote:
>
> > > Thanks for the reply. I tried what you suggested, still with the same
> > > results.
> > > I also tried some things from another discussion I found on here, but
> > > that didn't work either.
> > > I am using TG 1.0 and SQLObject
>
> > > # tried both with and without the extra URI setting
> > > from turbogears import database
> > > database.set_db_uri('postgres://URI')
>
> > > # No errors or exceptions from this code, but same result, TG/
> > > SQLObject hangs
> > > # on to the DB connection and doesn't let it go.
> > > from sqlobject.util.threadinglocal import local as threading_local
> > > hub.threadingLocal = threading_local()
> > > hub.begin()
> > > loads = Test.select()
> > > hub.commit()
> > > hub.end()
>
> > > The scheduler in production runs every 10 minutes and with 100 DB
> > > connections available, I have to restart TG every 16 hours at to make
> > > sure we don't get DB connect limited exceeded errors. I have debug and
> > > debugOutput turned on for SQLObject but I am not seeing anything that
> > > is really helping me figure out what I should do. I will look for more
> > > information about acquiring and releasing DB connections from a
> > > scheduler thread.
>
> > > On Feb 17, 2:29 am, "Richard Clark" <[EMAIL PROTECTED]> wrote:
>
> > > > Ok, keep in mind this stuff is for tg 1.0, it may not apply to later
> > > > versions.
>
> > > > The important thing to remember about the scheduler is that you're
> > > > running in a "user" created thread when your job gets called, you're
> > > > not in a tg created thread.
>
> > > > As such, the database needs managing in the same fashion it would if
> > > > you were running your own thread. You need to acquire a thread local
> > > > store, create a new database connection, etc.
>
> > > > It works basically like this, in your scheduled function:
>
> > > > def MyScheduledFunction:
> > > > # By getting the correct threading_local, the hub will presume it
> > > > isn't already connected (if this thread hasn't already been used) and
> > > > get you a connection
> > > > from sqlobject.util.threadinglocal import local as threading_local
> > > > hub.threadingLocal = threading_local()
> > > > hub.begin()
> > > > # now you can do your stuff
> > > > hub.commit()
>
> > > > This may or may not help with your particular problem, I have dozens
> > > > of solutions to things that slowly go out of fashion as turbogears
> > > > moves on :)
>
> > > > > Everytime the job runs (10 seconds) it opens a Postgres connection and
> > > > > leaves it in the idle in tranaction state. I can't figure out how to
> > > > > get the job to properly close the connection. I tried adding
> > > > > hub.begin() before and hub.end() after the select() call , but with
> > > > > the same results. Any ideas or nudges in the right direction? Thanks.
>
> > > > > I am using a file called jobs.py
>
> > > > > from model import Test, hub
> > > > > def test_schedule():
> > > > > test_result = Test.select()
> > > > > return
>
> > > > > def schedule():
> > > > > from turbogears import scheduler
> > > > > scheduler.add_interval_task(action=test_schedule,
> > > > > taskname='Test Schedule',
> > > > > initialdelay=0,
> > > > > interval=10)
> > > > > return
>
> > > > > In my start-test.py I have the entry
>
> > > > > from test import jobs
> > > > > jobs.schedule()
--~--~---------~--~----~------------~-------~--~----~
You received this message because you are subscribed to the Google Groups
"TurboGears" group.
To post to this group, send email to [email protected]
To unsubscribe from this group, send email to [EMAIL PROTECTED]
For more options, visit this group at
http://groups.google.com/group/turbogears?hl=en
-~----------~----~----~----~------~----~------~--~---
