Skip to content

Commit

Permalink
fix: one more syntax error
Browse files Browse the repository at this point in the history
  • Loading branch information
bodom0015 committed Dec 19, 2023
1 parent 4f199b8 commit 741d16a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/kubewatcher.py
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ def run(self):
try:
# List all pods in watched namespace to get resource_version
namespaced_jobs: V1JobList = kubejob.api_batch_v1.list_namespaced_job(namespace=kubejob.get_namespace())
resource_version = namespaced_jobs.metadata['resource_version'] if 'resource_version' in namespaced_jobs.metadata else resource_version
resource_version = namespaced_jobs.metadata.resource_version if namespaced_jobs.metadata.resource_version else resource_version

# Then, watch for new events using the most recent resource_version
# Resource version is used to keep track of stream progress (in case of resume/retry)
Expand Down

0 comments on commit 741d16a

Please sign in to comment.