Marko Kreen [Wed, 28 Oct 2009 13:34:27 +0000 (15:34 +0200)]
dbstruct: Remove ONLY from ADD CONSTRAINT.
Parent table cannot have contraints that the childs do not have.
Marko Kreen [Mon, 2 Nov 2009 13:45:47 +0000 (15:45 +0200)]
Makefile: pass sub-* target exit status back
Marko Kreen [Wed, 14 Oct 2009 15:03:54 +0000 (18:03 +0300)]
python/: Add --version switch to all scripts.
Based on patch by Hannu Krosing
Marko Kreen [Wed, 14 Oct 2009 14:34:40 +0000 (17:34 +0300)]
londiste: make copy unlink inherited table from it's parents
Otherwise we cannot drop constraints.
Unlink from childs is not needed, so they are left as-is.
Patch by Hannu Krosing
Marko Kreen [Wed, 14 Oct 2009 13:47:31 +0000 (16:47 +0300)]
skytools.DBScript: safer pidfile writing
- signal_pidfile: Clarify ValueError error message. Thrown usually
on empty pidfiles, the error messega will now mention the pidfile name.
- run_single_process: restructure pidfile writing, so that
the pidfile is removed if .write() failed, but not when open() failed.
This should avoid the chance that empty pidfiles are hanging around.
Marko Kreen [Wed, 14 Oct 2009 13:37:17 +0000 (16:37 +0300)]
python/skytools: add doctest-based regtests to few non-sql functions
Seems to be better testing method than ad-hoc scripts. They will
serve as examples too.
Also fix few minor problems found in the process:
- parse_pgarray: check if str ends with }
- parse_pgarray: support NULL
- quote_fqident: add 'public.' schema to idents without schema
- fq_name_parts: return always list
Marko Kreen [Wed, 14 Oct 2009 13:30:18 +0000 (16:30 +0300)]
sql/pgq/triggers: magic fields to set event fields directly.
pgq.sqltriga() / pgq.logutriga() now consider following fields magic:
_pgq_ev_type
_pgq_ev_data
_pgq_ev_extra1
_pgq_ev_extra2
_pgq_ev_extra3
_pgq_ev_extra4
If any of them is present in table, corresponding event field is set directly
to it's value, overriding value generated by trigger.
Marko Kreen [Tue, 6 Oct 2009 15:01:23 +0000 (18:01 +0300)]
Merge remote branch 'martin/master'
Martin Pihlak [Tue, 6 Oct 2009 14:12:19 +0000 (17:12 +0300)]
Fix the pg_[x]log rsyncing code to leave out directory contents.
Marko Kreen [Mon, 21 Sep 2009 13:25:00 +0000 (16:25 +0300)]
dbscript: rename connection_setup to connection_hook
Marko Kreen [Mon, 21 Sep 2009 13:13:27 +0000 (16:13 +0300)]
DBScript: Simplify looping and docstring handling
- looping: remove .do_single_loop and .looping variables, let only .loop_delay
control looping. If loop_delay is missing from confing or 0, then
instead sleep, the script will exit.
- docstr: print docstring fragments recursively, so each class
needs to only document its own parameters.
- londiste.py: use Replicator class to print default config as it has
proper class inheritance.
Marko Kreen [Mon, 21 Sep 2009 13:12:56 +0000 (16:12 +0300)]
Add various junk to .gitignore
Marko Kreen [Mon, 21 Sep 2009 11:37:28 +0000 (14:37 +0300)]
sqltools: make mk_update_sql()/mk_delete_sql() use ONLY
This will make urlencoded events behave same as sql events.
Marko Kreen [Mon, 21 Sep 2009 11:29:51 +0000 (14:29 +0300)]
sql/pgq: trigger fixes
- pgq.logutriga() did not put custom pkey= value into events.
- pgq.logutriga() and pgq.sqltriga() did allow UPDATE and DELETE
on tables without pkey, running into SQL errors downstream.
They should throw error in such case.
Marko Kreen [Thu, 17 Sep 2009 08:46:10 +0000 (11:46 +0300)]
pgq.maint_retry_events(): lock table to allow only single mover
Use SHARE UPDATE EXCLUSIVE lock, which will not conflict with inserts.
Martin Pihlak [Tue, 15 Sep 2009 12:24:01 +0000 (15:24 +0300)]
Disable archive_command in restored postgresql.conf
archive_command is set to /bin/true instead of disabling archive_mode
This avoids the extra reconfiguration restart when the slave is actually
booted and promoted to master. Based on patch by Mark Kirkwoord.
Marko Kreen [Fri, 11 Sep 2009 17:37:11 +0000 (20:37 +0300)]
pgq.Consumer: use next_batch_custom()
This brings new configurable params:
pgq_min_delay, pgq_min_count, pgq_min_lag
make them also reloadable via SIGHUP.
Marko Kreen [Fri, 11 Sep 2009 12:28:24 +0000 (15:28 +0300)]
pgq.get_batch_info(): show also seq values
Marko Kreen [Fri, 11 Sep 2009 11:21:32 +0000 (14:21 +0300)]
pgq.Consumer: use lazy_fetch by default
New default_lazy_fetch class var to allow subclasses to turn it off.
Marko Kreen [Fri, 11 Sep 2009 11:20:48 +0000 (14:20 +0300)]
pgq.Consumer: use get_batch_cursor()
Marko Kreen [Fri, 11 Sep 2009 11:08:51 +0000 (14:08 +0300)]
pgq.next_batch_custom(): extended next_batch
Supports create batch of several ticks and also forced lag.
Marko Kreen [Fri, 11 Sep 2009 10:55:28 +0000 (13:55 +0300)]
pgq: make test should also install
Marko Kreen [Thu, 10 Sep 2009 14:54:34 +0000 (17:54 +0300)]
nodeinfo: show failed consumers
Marko Kreen [Thu, 10 Sep 2009 14:54:10 +0000 (17:54 +0300)]
cascadeadmin: fix provider_node ref
Marko Kreen [Thu, 10 Sep 2009 14:53:39 +0000 (17:53 +0300)]
refresh libusual
Marko Kreen [Thu, 10 Sep 2009 11:33:59 +0000 (14:33 +0300)]
todo update
Marko Kreen [Thu, 10 Sep 2009 11:33:22 +0000 (14:33 +0300)]
configure: add usual_port_check
Marko Kreen [Thu, 10 Sep 2009 11:27:21 +0000 (14:27 +0300)]
cascadedconsumer: use exception_hook to store error in db
Marko Kreen [Thu, 10 Sep 2009 11:04:35 +0000 (14:04 +0300)]
DBScript: exception_hook
Marko Kreen [Thu, 10 Sep 2009 11:53:10 +0000 (14:53 +0300)]
londiste add-seq/tbl: fix --create bug
Marko Kreen [Thu, 10 Sep 2009 10:36:47 +0000 (13:36 +0300)]
python/: clean up imports
- Remove unused imports
- Remove relative imports
Marko Kreen [Thu, 10 Sep 2009 11:33:48 +0000 (14:33 +0300)]
run.lint: check all packages
Also tune down style warnings
Marko Kreen [Wed, 9 Sep 2009 11:09:40 +0000 (14:09 +0300)]
londiste: on error, apply sql on-by-one
Check whether last loop got error (work_state = -1)
and apply sql one-by-one if thats true.
Also, apply TRUNCATE separately from other SQL.
Marko Kreen [Wed, 9 Sep 2009 11:02:01 +0000 (14:02 +0300)]
skytools.DBScript: make work_state = -1 signal exception
If exception was thrown, set work_state = -1, to let consumer
handle next work differently.
Marko Kreen [Wed, 9 Sep 2009 10:52:58 +0000 (13:52 +0300)]
pgq.CoopConsumer for Python
Simply wrapper around Consumer which redirects few calls to pgq_coop schema.
Marko Kreen [Wed, 2 Sep 2009 17:56:41 +0000 (20:56 +0300)]
todo: merge queue loader to londiste
Marko Kreen [Wed, 2 Sep 2009 17:55:53 +0000 (20:55 +0300)]
doc: fix html generation
Marko Kreen [Wed, 2 Sep 2009 17:55:25 +0000 (20:55 +0300)]
refresh libusual
Marko Kreen [Thu, 27 Aug 2009 08:45:55 +0000 (11:45 +0300)]
londiste.local_add_table: use information_schema to get trigger info
This allows to filter out only AFTER triggers without
depending on low-level details of pg_catalog.
Marko Kreen [Thu, 27 Aug 2009 08:45:16 +0000 (11:45 +0300)]
londiste: helper function to extract parts from fqname
Marko Kreen [Thu, 27 Aug 2009 08:27:42 +0000 (11:27 +0300)]
Fetch libusual fix
Marko Kreen [Tue, 21 Jul 2009 11:19:50 +0000 (14:19 +0300)]
Merge commit 'martin/master'
Martin Pihlak [Tue, 21 Jul 2009 11:12:57 +0000 (14:12 +0300)]
Remove unused --overwrite option.
Martin Pihlak [Tue, 21 Jul 2009 10:44:06 +0000 (13:44 +0300)]
Create pg_xlog/archive_status directory for slave restore.
Patch by Mark Kirkwood.
Marko Kreen [Wed, 8 Jul 2009 15:13:12 +0000 (18:13 +0300)]
libusual: refresh
Marko Kreen [Wed, 8 Jul 2009 15:09:04 +0000 (18:09 +0300)]
sql/londiste: refresh regtests for table_attrs
Marko Kreen [Wed, 8 Jul 2009 15:07:41 +0000 (18:07 +0300)]
local_add_table: FOUND does not work with MAX()
Marko Kreen [Wed, 8 Jul 2009 15:01:11 +0000 (18:01 +0300)]
londiste: fix missing END IF and some ws in local_add_table()
Dimitri Fontaine [Wed, 8 Jul 2009 14:45:36 +0000 (16:45 +0200)]
Warn user when adding a table to replicate if it has triggers which will fire before londiste ones, and change trigger name to prefix with '_londiste_', per discussion.
Martin Pihlak [Tue, 9 Jun 2009 07:48:31 +0000 (10:48 +0300)]
Make --expect-sync use londiste.local_set_table_state()
Martin Pihlak [Tue, 9 Jun 2009 07:23:12 +0000 (10:23 +0300)]
fixed display_table to properly display long table names.
Martin Pihlak [Tue, 9 Jun 2009 07:08:39 +0000 (10:08 +0300)]
Reduced logging level for maintenance and retry commands.
Marko Kreen [Mon, 8 Jun 2009 14:27:49 +0000 (17:27 +0300)]
londiste: make --expect-sync work
Marko Kreen [Mon, 8 Jun 2009 10:14:45 +0000 (13:14 +0300)]
todo update
Marko Kreen [Mon, 8 Jun 2009 08:07:08 +0000 (11:07 +0300)]
Merge commit 'martin/master'
Marko Kreen [Mon, 8 Jun 2009 08:03:49 +0000 (11:03 +0300)]
pgq_node.set_consumer_error(): to store pending error condition
this may help admin tools which can show also pending error
of why processing last batch failed.
Martin Pihlak [Mon, 8 Jun 2009 07:46:19 +0000 (10:46 +0300)]
Fixed variable name mismatch.
Martin Pihlak [Mon, 8 Jun 2009 07:42:51 +0000 (10:42 +0300)]
Merge branch 'master' of git://github.com/markokr/skytools-dev
Marko Kreen [Mon, 8 Jun 2009 07:25:59 +0000 (10:25 +0300)]
pgq_node.set_global_watermark: ignore missing ticks
set_global_watermark() can be called with non-existing tick-ids
if worker is processing old batches.
Marko Kreen [Fri, 5 Jun 2009 12:34:06 +0000 (15:34 +0300)]
buildsystem reorg
- put python modules under 'skytools-3.0'
- install pkgloader separately
- install scripts in Makefile instead setup.py (it did not support rename)
removing .py afterwards is dangerous as we may overwrite old scripts.
- move setup.py under misc/ as it really is not usable standalone
- drop override PYTHON
Marko Kreen [Fri, 5 Jun 2009 10:32:09 +0000 (13:32 +0300)]
doc: clean up files under doc/
- move extra.css, fixman.py and getattrs.py under misc/
- move .html, .xml, .1 files to subdir
- remove londiste.5
- standardise: pgq-admin->pgqadm, londiste.cmdline -> londiste
Marko Kreen [Fri, 5 Jun 2009 10:29:05 +0000 (13:29 +0300)]
pkgloader module to be able to coexist with 2.x
Use scheme that pygtk uses to support parallel installations:
import pkgloader
pkgloader.require('skytools', '3.0')
import skytools
This will allow keeping old module installed by default and new
version is used only by request.
Marko Kreen [Fri, 5 Jun 2009 10:28:31 +0000 (13:28 +0300)]
move bulk_loader/cube_dispatcher/table_dispatcher to old/
The scripts are obsolete but kept as samples. To notify
that they are not maintained actively, move them away.
Marko Kreen [Thu, 4 Jun 2009 13:18:03 +0000 (16:18 +0300)]
londiste: replace skip_trunc columns with table attrs
this allows to store more extra data and avoid table
struct change for each item. only items that the
SQL code does not need to care about can be stored
that way.
Marko Kreen [Tue, 2 Jun 2009 10:33:14 +0000 (13:33 +0300)]
doc update
Martin Pihlak [Thu, 4 Jun 2009 13:28:10 +0000 (16:28 +0300)]
Merge branch 'master' of git://github.com/markokr/skytools-dev
Marko Kreen [Thu, 4 Jun 2009 13:22:14 +0000 (16:22 +0300)]
Merge commit 'martin/master'
Martin Pihlak [Thu, 4 Jun 2009 10:45:20 +0000 (13:45 +0300)]
Merge branch 'master' of git://github.com/markokr/skytools-dev
Martin Pihlak [Thu, 4 Jun 2009 10:42:49 +0000 (13:42 +0300)]
WalMgr backup retains symlinks for pg_log and pg_xlog.
Attempt to keep symlinks for pg_log and pg_xlog. Add a
new configuration parameter for controlling the behaviour.
Marko Kreen [Mon, 1 Jun 2009 14:02:24 +0000 (17:02 +0300)]
londiste: make compare/repair work with new cascade code
Marko Kreen [Mon, 1 Jun 2009 13:41:39 +0000 (16:41 +0300)]
update todo
Marko Kreen [Mon, 1 Jun 2009 13:32:08 +0000 (16:32 +0300)]
python/pgq: relaxed event handling
.tag_done() call is no more required. Events are by default in
'done' state.
In 2.x events were in 'retry' state by default, which was very bad
idea in retrospect. Changing them to 'untagged' and still requiring
tag_done() does not seem too good either. Original reasoning was to
detect and survive errors in scripts, but the result was only
confusion to everybody.
So instead of assuming that script may be buggy, now we assume
that script knows what it does. And only by explicit action
can they be tagged as retry.
Marko Kreen [Mon, 1 Jun 2009 13:01:37 +0000 (16:01 +0300)]
update TODO, fix londiste doc
Marko Kreen [Mon, 1 Jun 2009 13:01:01 +0000 (16:01 +0300)]
londiste: local_add_seq() - log seq name
Marko Kreen [Mon, 1 Jun 2009 12:51:54 +0000 (15:51 +0300)]
londiste: globbing, --all
Marko Kreen [Mon, 1 Jun 2009 09:30:33 +0000 (12:30 +0300)]
londiste: fix resync / missing commands
Asko Oja [Mon, 4 May 2009 14:02:39 +0000 (14:02 +0000)]
python scripts: Move template config to docstring.
* Template config is now in docstring to make to more
easy to keep up-to-date.
* dbscript: --ini option to show template config.
Marko Kreen [Mon, 1 Jun 2009 06:25:56 +0000 (09:25 +0300)]
pgqd: use strlist
Marko Kreen [Mon, 1 Jun 2009 06:14:41 +0000 (09:14 +0300)]
pgqd: support database_list
Marko Kreen [Mon, 1 Jun 2009 07:12:49 +0000 (10:12 +0300)]
upgrade libusual
Marko Kreen [Fri, 29 May 2009 11:46:01 +0000 (14:46 +0300)]
cascade: more takeover work
Marko Kreen [Wed, 13 May 2009 14:23:39 +0000 (17:23 +0300)]
docheck: allow files from cmdline
Marko Kreen [Wed, 13 May 2009 14:23:01 +0000 (17:23 +0300)]
dbscript: better desc for -q/-v
Marko Kreen [Wed, 13 May 2009 11:15:13 +0000 (14:15 +0300)]
cascade status: work on broken tree, show node type
- Show node type after name
- Allow several roots, take nodes with missing parents as roots
It still cannot work on cycles. But as the change-provider code
should avoid making those, maybe it's not worth worrying about.
Marko Kreen [Wed, 13 May 2009 10:22:49 +0000 (13:22 +0300)]
tests: move common test code to under tests/*.sh
Marko Kreen [Fri, 24 Apr 2009 14:33:39 +0000 (17:33 +0300)]
cascade: takeover
Instead of switchover/failover commands have 'takeover' command,
to be launched from new node.
Marko Kreen [Mon, 4 May 2009 12:35:02 +0000 (15:35 +0300)]
doc updates
Marko Kreen [Wed, 6 May 2009 10:36:20 +0000 (13:36 +0300)]
Merge commit 'askotm/master'
Marko Kreen [Wed, 6 May 2009 10:28:12 +0000 (13:28 +0300)]
DBScript: bad argument reference in run_safely
Marko Kreen [Wed, 6 May 2009 10:27:35 +0000 (13:27 +0300)]
CascadeAdmin: add missing import
Marko Kreen [Wed, 6 May 2009 10:26:50 +0000 (13:26 +0300)]
skytools.Config: getdict() method
Marko Kreen [Mon, 4 May 2009 11:15:46 +0000 (14:15 +0300)]
sql/*: update regtests with new messages
Asko Tiidumaa [Wed, 6 May 2009 08:01:47 +0000 (08:01 +0000)]
fixed error message
Asko Tiidumaa [Wed, 6 May 2009 08:01:08 +0000 (08:01 +0000)]
fixed error message
Asko Tiidumaa [Wed, 6 May 2009 08:00:13 +0000 (08:00 +0000)]
fixed two error messages that were copied from log(u)triga
Asko Oja [Mon, 4 May 2009 12:22:25 +0000 (12:22 +0000)]
Add querybuilder into sql tools
Querybulder is used to manage parametrisized queries both in
plpython/dbservice stored procedures and python scripts.
Marko Kreen [Mon, 4 May 2009 11:06:47 +0000 (14:06 +0300)]
Merge commit 'martin/master'
Marko Kreen [Mon, 4 May 2009 10:47:59 +0000 (13:47 +0300)]
pgq_node, londiste: improve log messages from db
londiste.global_add_table()
londiste.global_remove_table()
pgq_node.set_global_watermark()
- Replace 'Ok' with actual sentence
londiste.root_check_seqs():
- improved message, downgrade to debug level
pgq_node.set_subscriber_watermark():
- improve message
- check tick value sanity
Marko Kreen [Mon, 4 May 2009 10:35:47 +0000 (13:35 +0300)]
python/pgq/cascade: proper process_root_node() calling
CascadedWorker did not call parent class method.
Also remove pointless logging from CascadedConsumer.
Marko Kreen [Mon, 4 May 2009 10:31:02 +0000 (13:31 +0300)]
pgq.register_consumer_at(): update last seen timestamp on position move