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

Increased to 6 minutes savepoint await timeout

Author: tutss

.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]+))?

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)

setup.py

@@ -1,6 +1,6 @@
 from setuptools import setup
 
-VERSION = '0.3.4'
+VERSION = '0.3.6'
 
 install_requires = [
     'requests==2.22.0',

version

@@ -1 +1 @@
-0.3.4
+0.3.6