projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'main' into 21440-process-panel-reorg
[arvados.git]
/
sdk
/
python
/
arvados
/
stream.py
diff --git
a/sdk/python/arvados/stream.py
b/sdk/python/arvados/stream.py
index 86ae8a59efd53e8bb59743643207896b6db26418..37cd5d7db89f626c24560e0e965408d7de1191aa 100644
(file)
--- a/
sdk/python/arvados/stream.py
+++ b/
sdk/python/arvados/stream.py
@@
-1,3
+1,7
@@
+# Copyright (C) The Arvados Authors. All rights reserved.
+#
+# SPDX-License-Identifier: Apache-2.0
+
from __future__ import print_function
from __future__ import absolute_import
from future.utils import listvalues
from __future__ import print_function
from __future__ import absolute_import
from future.utils import listvalues
@@
-16,11
+20,13
@@
from arvados.retry import retry_method
from arvados.keep import *
from . import config
from . import errors
from arvados.keep import *
from . import config
from . import errors
+from . import util
from ._normalize_stream import normalize_stream
class StreamReader(object):
from ._normalize_stream import normalize_stream
class StreamReader(object):
+ @util._deprecated('3.0', 'arvados.collection.Collecttion')
def __init__(self, tokens, keep=None, debug=False, _empty=False,
def __init__(self, tokens, keep=None, debug=False, _empty=False,
- num_retries=0):
+ num_retries=
1
0):
self._stream_name = None
self._data_locators = []
self._files = collections.OrderedDict()
self._stream_name = None
self._data_locators = []
self._files = collections.OrderedDict()