snjypl commented on issue #21087: URL: https://github.com/apache/airflow/issues/21087#issuecomment-1121079448
the code you shared is not really a good way to demonstrate `BOOKMARK`. but still: > for i in watcher.stream(v1.list_namespaced_pod, namespace, resource_version=1, allow_watch_bookmarks=True,timeout_seconds=2): > resource_version = i['object'].metadata.resource_version shouldn't it be `resource_version = last_resource_version` > first loop 380775416 > The watch disconnected, the last known resource version was 380775416 the resource_version in the first loop and the error message is same. again, it has nothing to do with bookmark. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
