Skip to content

Commit 7b37934

Browse files
authored
Add retry_409_path to service request in _get_or_create (#260)
1 parent e6e72d2 commit 7b37934

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

metaflow/metadata/service.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,7 @@ def create_object():
178178
task_id,
179179
tags + self.sticky_tags,
180180
sys_tags + self.sticky_sys_tags)
181-
return self._request(self._monitor, create_path, data)
181+
return self._request(self._monitor, create_path, data, obj_path)
182182

183183
always_create = False
184184
obj_path = self._obj_path(self._flow_name, run_id, step_name, task_id)
@@ -241,7 +241,7 @@ def _request(cls, monitor, path, data=None, retry_409_path=None):
241241
# instead of retrying the post we retry with a get since
242242
# the record is guaranteed to exist
243243
if retry_409_path:
244-
return self._request(retry_409_path)
244+
return self._request(monitor, retry_409_path)
245245
else:
246246
return
247247
elif resp.status_code != 503:

0 commit comments

Comments
 (0)