diff --git a/import_to_es.py b/import_to_es.py
index e292386..106cbc1 100644
--- a/import_to_es.py
+++ b/import_to_es.py
@@ -22,7 +22,7 @@ bar = progressbar.ProgressBar(
             ' (', progressbar.ETA(), ') ',
             ])
 
-es = Elasticsearch()
+es = Elasticsearch(timeout=30)
 ic = IndicesClient(es)
 
 # turn into thing that elasticsearch indexes. We flatten in
diff --git a/sync_es.py b/sync_es.py
index c22fbcb..4cbd9f2 100644
--- a/sync_es.py
+++ b/sync_es.py
@@ -51,7 +51,7 @@ NT_DB = 'nyaav2'
 with open(SAVE_LOC) as f:
     pos = json.load(f)
 
-es = Elasticsearch()
+es = Elasticsearch(timeout=30)
 
 stream = BinLogStreamReader(
         # TODO parse out from config.py or something