Merge pull request #18 from Cobliteam/nt-updated-again-timeout

Increased to 6 minutes savepoint await timeout
Cobliteam · Sep 11, 2019 · fbcd185 · fbcd185
2 parents b8eae69 + 7287445
commit fbcd185
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/.bumpversion.cfg b/.bumpversion.cfg
@@ -1,5 +1,5 @@
 [bumpversion]
-current_version = 0.3.4
+current_version = 0.3.6
 commit = True
 tag = False
 parse = (?P<major>\d+)\.(?P<minor>\d+)\.(?P<patch>\d+)(-(?P<release>[A-Z]+))?

diff --git a/flink_scrat/job_manager_connector.py b/flink_scrat/job_manager_connector.py
@@ -29,7 +29,7 @@ def delete_jar(self, jar_id):
 
         return response
 
-    def _await_savepoint_completion(self, job_id, request_id, max_retries=60, retry_sleep_seconds=4):
+    def _await_savepoint_completion(self, job_id, request_id, max_retries=180, retry_sleep_seconds=2):
         in_progess_status = 'IN_PROGRESS'
         for try_num in range(0, max_retries):
             trigger_info = self.savepoint_trigger_info(job_id, request_id)

diff --git a/setup.py b/setup.py
@@ -1,6 +1,6 @@
 from setuptools import setup
 
-VERSION = '0.3.4'
+VERSION = '0.3.6'
 
 install_requires = [
     'requests==2.22.0',

diff --git a/version b/version
@@ -1 +1 @@
-0.3.4
+0.3.6