File tree Expand file tree Collapse file tree 1 file changed +0
-15
lines changed Expand file tree Collapse file tree 1 file changed +0
-15
lines changed Original file line number Diff line number Diff line change 6
6
import psycopg2 .extensions
7
7
import singer
8
8
import singer .schema
9
- import signal
10
9
11
10
from singer import utils , metadata , get_bookmark
12
11
from singer .catalog import Catalog
22
21
dump_catalog , clear_state_on_replication_change ,
23
22
is_selected_via_metadata , refresh_streams_schema , any_logical_streams )
24
23
25
-
26
- psycopg2 .extensions .set_wait_callback (psycopg2 .extras .wait_select )
27
-
28
-
29
- def handle_signal (sig = None , frame = None ):
30
- """
31
- signal handler for sigterms
32
- raise sigint because that's how psycopg2 aborts running queries
33
- """
34
- raise KeyboardInterrupt ("RECEIVED SIGTERM. RAISING SIGINT TO ABORT POSTGRES QUERY" )
35
-
36
-
37
- signal .signal (signal .SIGTERM , handle_signal )
38
-
39
24
LOGGER = singer .get_logger ('tap_postgres' )
40
25
41
26
REQUIRED_CONFIG_KEYS = [
You can’t perform that action at this time.
0 commit comments