setup min_processes to 0 for all workers
[APKPM.git] / lib / APKPM / Store.pm
index d63f481..054e53c 100644 (file)
@@ -35,17 +35,18 @@ sub pg_insert {
        $sth->execute( map { $h->{$_} } @c );
 }
 
-sub insert : Job : Decode(d_json) {
+sub insert : Job : Decode(d_json) : MinProcesses(0) {
        my ( $self, $job, $workload ) = @_;
        my $table = delete $workload->{_table} || die "no _table";
        $self->pg_insert($table => $workload);
 }
 
-sub sql : Job : Encode(e_json) {
+sub sql : Job : Encode(e_json) : MinProcesses(0) {
        my ( $self, $job, $workload ) = @_;
 
        my $sth = $self->dbh->prepare($workload);
-       my $rows = $sth->execute;
+       my $rows = eval { $sth->execute };
+       return { error => $@ } if $@;
 
        warn "# $rows rows get_username_table $workload\n";