Allow all commads to be sent to workers in pool when preserve_commit_order=false

kelvich · kelvich · commit 7123227389b5 · 2017-11-13T02:23:42.000+03:00
diff --git a/pglogical_receiver.c b/pglogical_receiver.c
@@ -577,7 +577,7 @@ pglogical_receiver_main(Datum main_arg)
 										}
 									} else {
 										/* all other commits should be applied in place */
-										Assert(stmt[1] == PGLOGICAL_PREPARE || stmt[1] == PGLOGICAL_COMMIT || stmt[1] == PGLOGICAL_PRECOMMIT_PREPARED);
+										// Assert(stmt[1] == PGLOGICAL_PREPARE || stmt[1] == PGLOGICAL_COMMIT || stmt[1] == PGLOGICAL_PRECOMMIT_PREPARED);
 										MtmExecute(buf.data, buf.used);
 									}
 								}

Original file line number	Diff line number	Diff line change
`@@ -577,7 +577,7 @@ pglogical_receiver_main(Datum main_arg)`
`577`	`577`	`}`
`578`	`578`	`} else {`
`579`	`579`	`/* all other commits should be applied in place */`
`580`		`- Assert(stmt[1] == PGLOGICAL_PREPARE \|\| stmt[1] == PGLOGICAL_COMMIT \|\| stmt[1] == PGLOGICAL_PRECOMMIT_PREPARED);`
	`580`	`+ // Assert(stmt[1] == PGLOGICAL_PREPARE \|\| stmt[1] == PGLOGICAL_COMMIT \|\| stmt[1] == PGLOGICAL_PRECOMMIT_PREPARED);`
`581`	`581`	`MtmExecute(buf.data, buf.used);`
`582`	`582`	`}`
`583`	`583`	`}`