Skip to content

Threadsafe

safe_add(kosh_obj, add_obj)

A threadsafe version of Kosh's "add" method.

Parameters:

kosh_obj: kosh object A kosh object. add_obj: kosh object A kosh object to add to kosh_obj.

Returns:

object: The result of calling kosh_obj.add(add_obj)

Source code in kosh/threadsafe.py 
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
@threadsafe_decorators.threadsafe_call(NUM_TRIES, PATIENCE)
def safe_add(kosh_obj, add_obj):
    """
    A threadsafe version of Kosh's "add" method.

    Parameters:
    -----------
    kosh_obj: kosh object
        A kosh object.
    add_obj: kosh object
        A kosh object to add to kosh_obj.

    Returns:
    --------
    object:
        The result of calling kosh_obj.add(add_obj)
    """
    return kosh_obj.add(add_obj)

safe_associate(dataset, **kw_args)

A threadsafe version of Kosh's "associate" method.

Parameters:

dataset: Kosh dataset A kosh dataset that has the "associate" method.

Returns:

object: The result of calling dataset.associate(**kw_args)

Source code in kosh/threadsafe.py 
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
@threadsafe_decorators.threadsafe_call(NUM_TRIES, PATIENCE)
def safe_associate(dataset, **kw_args):
    """
    A threadsafe version of Kosh's "associate" method.

    Parameters:
    -----------
    dataset: Kosh dataset
        A kosh dataset that has the "associate" method.

    Returns:
    --------
    object:
        The result of calling dataset.associate(**kw_args)
    """
    return dataset.associate(**kw_args)

safe_clone(kosh_obj, **kw_args)

A threadsafe version of Kosh's "clone" method.

Parameters:

kosh_obj: kosh object A kosh object.

Returns:

object: The result of calling kosh_obj.clone(**kw_args)

Source code in kosh/threadsafe.py 
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
@threadsafe_decorators.threadsafe_call(NUM_TRIES, PATIENCE)
def safe_clone(kosh_obj, **kw_args):
    """
    A threadsafe version of Kosh's "clone" method.

    Parameters:
    -----------
    kosh_obj: kosh object
        A kosh object.

    Returns:
    --------
    object:
        The result of calling kosh_obj.clone(**kw_args)
    """
    return kosh_obj.clone(**kw_args)

safe_create(kosh_obj, **kw_args)

A threadsafe version of Kosh's "create" method.

Parameters:

kosh_obj: object A kosh object that has the "create" method.

Returns:

object: The result of calling kosh_obj.create(**kw_args)

Source code in kosh/threadsafe.py 
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
@threadsafe_decorators.threadsafe_call(NUM_TRIES, PATIENCE)
def safe_create(kosh_obj, **kw_args):
    """
    A threadsafe version of Kosh's "create" method.

    Parameters:
    -----------
    kosh_obj: object
        A kosh object that has the "create" method.

    Returns:
    --------
    object:
        The result of calling kosh_obj.create(**kw_args)
    """
    return kosh_obj.create(**kw_args)

safe_create_ensemble(store, **kw_args)

A threadsafe version of Kosh's "create_ensemble" method.

Parameters:

store: Kosh store A kosh store that has the "create_ensemble" method.

Returns:

object: The result of calling store.create_ensemble(**kw_args)

Source code in kosh/threadsafe.py 
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
@threadsafe_decorators.threadsafe_call(NUM_TRIES, PATIENCE)
def safe_create_ensemble(store, **kw_args):
    """
    A threadsafe version of Kosh's "create_ensemble" method.

    Parameters:
    -----------
    store: Kosh store
        A kosh store that has the "create_ensemble" method.

    Returns:
    --------
    object:
        The result of calling store.create_ensemble(**kw_args)
    """
    return store.create_ensemble(**kw_args)

safe_delete(kosh_obj, del_object)

A threadsafe version of Kosh's "delete" method.

Parameters:

kosh_obj: object A kosh object that has the "delete" method. del_object: object The kosh object to delete.

Returns:

object: The result of calling kosh_obj.delete(del_object)

Source code in kosh/threadsafe.py 
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
@threadsafe_decorators.threadsafe_call(NUM_TRIES, PATIENCE)
def safe_delete(kosh_obj, del_object):
    """
    A threadsafe version of Kosh's "delete" method.

    Parameters:
    -----------
    kosh_obj: object
        A kosh object that has the "delete" method.
    del_object: object
        The kosh object to delete.

    Returns:
    --------
    object:
        The result of calling kosh_obj.delete(del_object)
    """
    return kosh_obj.delete(del_object)

safe_find(kosh_obj, **kw_args)

A threadsafe version of Kosh's "find" method.

IMPORTANT: Kosh's "find" methods return generators that don't perform database communications until the generator is executed. This means that we need to execute the generator inside of our threadsafe wrapper. This converts the return value to an iterator to conserve the return value interface. Note that this will have a small impact on performance, but it shouldn't be significant.

Parameters:

kosh_obj: kosh object A kosh object.

Returns:

object: The result of calling kosh_obj.find(**kw_args)

Source code in kosh/threadsafe.py 
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
@threadsafe_decorators.patient_find(NUM_TRIES, PATIENCE)
@threadsafe_decorators.threadsafe_call(NUM_TRIES, PATIENCE)
def safe_find(kosh_obj, **kw_args):
    """
    A threadsafe version of Kosh's "find" method.

    IMPORTANT: Kosh's "find" methods return generators that don't
    perform database communications until the generator is executed.
    This means that we need to execute the generator inside of
    our threadsafe wrapper. This converts the return value to
    an iterator to conserve the return value interface. Note that
    this will have a small impact on performance, but it shouldn't
    be significant.

    Parameters:
    -----------
    kosh_obj: kosh object
        A kosh object.

    Returns:
    --------
    object:
        The result of calling kosh_obj.find(**kw_args)
    """
    return iter(list(kosh_obj.find(**kw_args)))

safe_find_datasets(ensemble, **kw_args)

A threadsafe version of Kosh's "find_datasets" method.

IMPORTANT: Kosh's "find" methods return generators that don't perform database communications until the generator is executed. This means that we need to execute the generator inside of our threadsafe wrapper. This converts the return value to an iterator to conserve the return value interface. Note that this will have a small impact on performance, but it shouldn't be significant.

Parameters:

ensemble: kosh ensemble A kosh ensemble.

Returns:

object: The result of calling ensemble.find_datasets(**kw_args)

Source code in kosh/threadsafe.py 
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
@threadsafe_decorators.patient_find(NUM_TRIES, PATIENCE)
@threadsafe_decorators.threadsafe_call(NUM_TRIES, PATIENCE)
def safe_find_datasets(ensemble, **kw_args):
    """
    A threadsafe version of Kosh's "find_datasets" method.

    IMPORTANT: Kosh's "find" methods return generators that don't
    perform database communications until the generator is executed.
    This means that we need to execute the generator inside of
    our threadsafe wrapper. This converts the return value to
    an iterator to conserve the return value interface. Note that
    this will have a small impact on performance, but it shouldn't
    be significant.

    Parameters:
    -----------
    ensemble: kosh ensemble
        A kosh ensemble.

    Returns:
    --------
    object:
        The result of calling ensemble.find_datasets(**kw_args)
    """
    return iter(list(ensemble.find_datasets(**kw_args)))

safe_find_ensembles(store, **kw_args)

A threadsafe version of Kosh's "find_ensembles" method.

IMPORTANT: Kosh's "find" methods return generators that don't perform database communications until the generator is executed. This means that we need to execute the generator inside of our threadsafe wrapper. This converts the return value to an iterator to conserve the return value interface. Note that this will have a small impact on performance, but it shouldn't be significant.

Parameters:

store: kosh store A kosh store.

Returns:

object: The result of calling store.find_ensembles(**kw_args)

Source code in kosh/threadsafe.py 
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
@threadsafe_decorators.patient_find(NUM_TRIES, PATIENCE)
@threadsafe_decorators.threadsafe_call(NUM_TRIES, PATIENCE)
def safe_find_ensembles(store, **kw_args):
    """
    A threadsafe version of Kosh's "find_ensembles" method.

    IMPORTANT: Kosh's "find" methods return generators that don't
    perform database communications until the generator is executed.
    This means that we need to execute the generator inside of
    our threadsafe wrapper. This converts the return value to
    an iterator to conserve the return value interface. Note that
    this will have a small impact on performance, but it shouldn't
    be significant.

    Parameters:
    -----------
    store: kosh store
        A kosh store.

    Returns:
    --------
    object:
        The result of calling store.find_ensembles(**kw_args)
    """
    return iter(list(store.find_ensembles(**kw_args)))

safe_get_execution_graph(dataset, **kw_args)

A threadsafe version of Kosh's "get_execution_graph" method.

Parameters:

dataset: Kosh dataset A kosh dataset that has the "get_execution_graph" method.

Returns:

object: The result of calling dataset.get_execution_graph(**kw_args)

Source code in kosh/threadsafe.py 
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
@threadsafe_decorators.threadsafe_call(NUM_TRIES, PATIENCE)
def safe_get_execution_graph(dataset, **kw_args):
    """
    A threadsafe version of Kosh's "get_execution_graph" method.

    Parameters:
    -----------
    dataset: Kosh dataset
        A kosh dataset that has the "get_execution_graph" method.

    Returns:
    --------
    object:
        The result of calling dataset.get_execution_graph(**kw_args)
    """
    return dataset.get_execution_graph(**kw_args)

safe_kosh_get(kosh_obj, *args, **kw_args)

A threadsafe version of Kosh's "get" method.

Parameters:

kosh_obj: kosh object A kosh object.

Returns:

object: The result of calling kosh_obj.get(**kw_args)

Source code in kosh/threadsafe.py 
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
@threadsafe_decorators.threadsafe_call(NUM_TRIES, PATIENCE)
def safe_kosh_get(kosh_obj, *args, **kw_args):
    """
    A threadsafe version of Kosh's "get" method.

    Parameters:
    -----------
    kosh_obj: kosh object
        A kosh object.

    Returns:
    --------
    object:
        The result of calling kosh_obj.get(**kw_args)
    """
    return kosh_obj.get(*args, **kw_args)

safe_open(store, *args, **kw_args)

A threadsafe version of Kosh's "open" method.

Parameters:

store: Kosh store A kosh store that has the "open" method.

Returns:

object: The result of calling store.open(args, *kw_args)

Source code in kosh/threadsafe.py 
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
@threadsafe_decorators.threadsafe_call(NUM_TRIES, PATIENCE)
def safe_open(store, *args, **kw_args):
    """
    A threadsafe version of Kosh's "open" method.

    Parameters:
    -----------
    store: Kosh store
        A kosh store that has the "open" method.

    Returns:
    --------
    object:
        The result of calling store.open(*args, **kw_args)
    """
    return store.open(*args, **kw_args)