@@ -20,77 +20,77 @@ class AggregatedDatasetLength:
20
20
"""
21
21
Attributes:
22
22
type (ComputationType): Type of the computation.
23
+ encrypted (Union[Unset, bool]): True if computation result should be encrypted with the collective public key.
24
+ local_input_id (Union[Unset, str]): Unique identifier of a data object.
25
+ project_id (Union[Unset, str]): Unique identifier of a project.
23
26
dp_policy (Union[Unset, DPPolicy]): represents the disclosure prevention policy that enables toggling various
24
27
disclosure prevention mechanisms
25
28
cohort_id (Union[Unset, str]): Unique identifier of a data object.
29
+ wait (Union[Unset, bool]): Whether to wait synchronously for the computation result.
30
+ preprocessing_parameters (Union[Unset, ComputationPreprocessingParameters]): dataframe pre-processing parameters
31
+ applied to the input retrieved from the datasource, if applicable
32
+ timeout (Union[Unset, int]): The maximum amount of time in seconds the computation is allowed to run.
33
+ owner (Union[Unset, str]): The username of the user who started the computation.
26
34
data_source_parameters (Union[Unset, ComputationDataSourceParameters]): Parameters used to query the datasource
27
35
from each node before the computation
28
- encrypted (Union[Unset, bool]): True if computation result should be encrypted with the collective public key.
29
- input_data_object (Union[Unset, str]): Shared identifier of a data object.
30
- join_id (Union[Unset, str]): Unique identifier of a data object.
31
36
local (Union[Unset, bool]): True if the project's computation should run only with local data (not configured
32
37
the network)
33
38
local_input (Union[Unset, LocalInput]): If a local input is provided, the node initiating the computation will
34
39
use it instead of querying the datasource. This data is *not* shared to other nodes, only used for the duration
35
40
of the computation. The local input columns/values must be in the form {<column1>: [<value1>, <value2>, ...],
36
41
...}
37
- local_input_id (Union[Unset, str]): Unique identifier of a data object.
38
- owner (Union[Unset, str]): The username of the user who started the computation.
39
- preprocessing_parameters (Union[Unset, ComputationPreprocessingParameters]): dataframe pre-processing parameters
40
- applied to the input retrieved from the datasource, if applicable
41
- project_id (Union[Unset, str]): Unique identifier of a project.
42
- timeout (Union[Unset, int]): The maximum amount of time in seconds the computation is allowed to run.
43
- wait (Union[Unset, bool]): Whether to wait synchronously for the computation result.
42
+ input_data_object (Union[Unset, str]): Shared identifier of a data object.
43
+ join_id (Union[Unset, str]): Unique identifier of a data object.
44
44
features (Union[Unset, str]): Shared identifier of a data object.
45
45
"""
46
46
47
47
type : ComputationType
48
+ encrypted : Union [Unset , bool ] = UNSET
49
+ local_input_id : Union [Unset , str ] = UNSET
50
+ project_id : Union [Unset , str ] = UNSET
48
51
dp_policy : Union [Unset , "DPPolicy" ] = UNSET
49
52
cohort_id : Union [Unset , str ] = UNSET
53
+ wait : Union [Unset , bool ] = UNSET
54
+ preprocessing_parameters : Union [Unset , "ComputationPreprocessingParameters" ] = UNSET
55
+ timeout : Union [Unset , int ] = UNSET
56
+ owner : Union [Unset , str ] = UNSET
50
57
data_source_parameters : Union [Unset , "ComputationDataSourceParameters" ] = UNSET
51
- encrypted : Union [Unset , bool ] = UNSET
52
- input_data_object : Union [Unset , str ] = UNSET
53
- join_id : Union [Unset , str ] = UNSET
54
58
local : Union [Unset , bool ] = UNSET
55
59
local_input : Union [Unset , "LocalInput" ] = UNSET
56
- local_input_id : Union [Unset , str ] = UNSET
57
- owner : Union [Unset , str ] = UNSET
58
- preprocessing_parameters : Union [Unset , "ComputationPreprocessingParameters" ] = UNSET
59
- project_id : Union [Unset , str ] = UNSET
60
- timeout : Union [Unset , int ] = UNSET
61
- wait : Union [Unset , bool ] = UNSET
60
+ input_data_object : Union [Unset , str ] = UNSET
61
+ join_id : Union [Unset , str ] = UNSET
62
62
features : Union [Unset , str ] = UNSET
63
63
additional_properties : Dict [str , Any ] = attr .ib (init = False , factory = dict )
64
64
65
65
def to_dict (self ) -> Dict [str , Any ]:
66
66
type = self .type .value
67
67
68
+ encrypted = self .encrypted
69
+ local_input_id = self .local_input_id
70
+ project_id = self .project_id
68
71
dp_policy : Union [Unset , Dict [str , Any ]] = UNSET
69
72
if not isinstance (self .dp_policy , Unset ):
70
73
dp_policy = self .dp_policy .to_dict ()
71
74
72
75
cohort_id = self .cohort_id
76
+ wait = self .wait
77
+ preprocessing_parameters : Union [Unset , Dict [str , Any ]] = UNSET
78
+ if not isinstance (self .preprocessing_parameters , Unset ):
79
+ preprocessing_parameters = self .preprocessing_parameters .to_dict ()
80
+
81
+ timeout = self .timeout
82
+ owner = self .owner
73
83
data_source_parameters : Union [Unset , Dict [str , Any ]] = UNSET
74
84
if not isinstance (self .data_source_parameters , Unset ):
75
85
data_source_parameters = self .data_source_parameters .to_dict ()
76
86
77
- encrypted = self .encrypted
78
- input_data_object = self .input_data_object
79
- join_id = self .join_id
80
87
local = self .local
81
88
local_input : Union [Unset , Dict [str , Any ]] = UNSET
82
89
if not isinstance (self .local_input , Unset ):
83
90
local_input = self .local_input .to_dict ()
84
91
85
- local_input_id = self .local_input_id
86
- owner = self .owner
87
- preprocessing_parameters : Union [Unset , Dict [str , Any ]] = UNSET
88
- if not isinstance (self .preprocessing_parameters , Unset ):
89
- preprocessing_parameters = self .preprocessing_parameters .to_dict ()
90
-
91
- project_id = self .project_id
92
- timeout = self .timeout
93
- wait = self .wait
92
+ input_data_object = self .input_data_object
93
+ join_id = self .join_id
94
94
features = self .features
95
95
96
96
field_dict : Dict [str , Any ] = {}
@@ -100,34 +100,34 @@ def to_dict(self) -> Dict[str, Any]:
100
100
"type" : type ,
101
101
}
102
102
)
103
+ if encrypted is not UNSET :
104
+ field_dict ["encrypted" ] = encrypted
105
+ if local_input_id is not UNSET :
106
+ field_dict ["localInputID" ] = local_input_id
107
+ if project_id is not UNSET :
108
+ field_dict ["projectId" ] = project_id
103
109
if dp_policy is not UNSET :
104
110
field_dict ["DPPolicy" ] = dp_policy
105
111
if cohort_id is not UNSET :
106
112
field_dict ["cohortId" ] = cohort_id
113
+ if wait is not UNSET :
114
+ field_dict ["wait" ] = wait
115
+ if preprocessing_parameters is not UNSET :
116
+ field_dict ["preprocessingParameters" ] = preprocessing_parameters
117
+ if timeout is not UNSET :
118
+ field_dict ["timeout" ] = timeout
119
+ if owner is not UNSET :
120
+ field_dict ["owner" ] = owner
107
121
if data_source_parameters is not UNSET :
108
122
field_dict ["dataSourceParameters" ] = data_source_parameters
109
- if encrypted is not UNSET :
110
- field_dict ["encrypted" ] = encrypted
111
- if input_data_object is not UNSET :
112
- field_dict ["inputDataObject" ] = input_data_object
113
- if join_id is not UNSET :
114
- field_dict ["joinId" ] = join_id
115
123
if local is not UNSET :
116
124
field_dict ["local" ] = local
117
125
if local_input is not UNSET :
118
126
field_dict ["localInput" ] = local_input
119
- if local_input_id is not UNSET :
120
- field_dict ["localInputID" ] = local_input_id
121
- if owner is not UNSET :
122
- field_dict ["owner" ] = owner
123
- if preprocessing_parameters is not UNSET :
124
- field_dict ["preprocessingParameters" ] = preprocessing_parameters
125
- if project_id is not UNSET :
126
- field_dict ["projectId" ] = project_id
127
- if timeout is not UNSET :
128
- field_dict ["timeout" ] = timeout
129
- if wait is not UNSET :
130
- field_dict ["wait" ] = wait
127
+ if input_data_object is not UNSET :
128
+ field_dict ["inputDataObject" ] = input_data_object
129
+ if join_id is not UNSET :
130
+ field_dict ["joinId" ] = join_id
131
131
if features is not UNSET :
132
132
field_dict ["features" ] = features
133
133
@@ -143,6 +143,12 @@ def from_dict(cls: Type[T], src_dict: Dict[str, Any]) -> T:
143
143
d = src_dict .copy ()
144
144
type = ComputationType (d .pop ("type" ))
145
145
146
+ encrypted = d .pop ("encrypted" , UNSET )
147
+
148
+ local_input_id = d .pop ("localInputID" , UNSET )
149
+
150
+ project_id = d .pop ("projectId" , UNSET )
151
+
146
152
_dp_policy = d .pop ("DPPolicy" , UNSET )
147
153
dp_policy : Union [Unset , DPPolicy ]
148
154
if isinstance (_dp_policy , Unset ):
@@ -152,19 +158,26 @@ def from_dict(cls: Type[T], src_dict: Dict[str, Any]) -> T:
152
158
153
159
cohort_id = d .pop ("cohortId" , UNSET )
154
160
161
+ wait = d .pop ("wait" , UNSET )
162
+
163
+ _preprocessing_parameters = d .pop ("preprocessingParameters" , UNSET )
164
+ preprocessing_parameters : Union [Unset , ComputationPreprocessingParameters ]
165
+ if isinstance (_preprocessing_parameters , Unset ):
166
+ preprocessing_parameters = UNSET
167
+ else :
168
+ preprocessing_parameters = ComputationPreprocessingParameters .from_dict (_preprocessing_parameters )
169
+
170
+ timeout = d .pop ("timeout" , UNSET )
171
+
172
+ owner = d .pop ("owner" , UNSET )
173
+
155
174
_data_source_parameters = d .pop ("dataSourceParameters" , UNSET )
156
175
data_source_parameters : Union [Unset , ComputationDataSourceParameters ]
157
176
if isinstance (_data_source_parameters , Unset ):
158
177
data_source_parameters = UNSET
159
178
else :
160
179
data_source_parameters = ComputationDataSourceParameters .from_dict (_data_source_parameters )
161
180
162
- encrypted = d .pop ("encrypted" , UNSET )
163
-
164
- input_data_object = d .pop ("inputDataObject" , UNSET )
165
-
166
- join_id = d .pop ("joinId" , UNSET )
167
-
168
181
local = d .pop ("local" , UNSET )
169
182
170
183
_local_input = d .pop ("localInput" , UNSET )
@@ -174,41 +187,28 @@ def from_dict(cls: Type[T], src_dict: Dict[str, Any]) -> T:
174
187
else :
175
188
local_input = LocalInput .from_dict (_local_input )
176
189
177
- local_input_id = d .pop ("localInputID" , UNSET )
178
-
179
- owner = d .pop ("owner" , UNSET )
180
-
181
- _preprocessing_parameters = d .pop ("preprocessingParameters" , UNSET )
182
- preprocessing_parameters : Union [Unset , ComputationPreprocessingParameters ]
183
- if isinstance (_preprocessing_parameters , Unset ):
184
- preprocessing_parameters = UNSET
185
- else :
186
- preprocessing_parameters = ComputationPreprocessingParameters .from_dict (_preprocessing_parameters )
187
-
188
- project_id = d .pop ("projectId" , UNSET )
189
-
190
- timeout = d .pop ("timeout" , UNSET )
190
+ input_data_object = d .pop ("inputDataObject" , UNSET )
191
191
192
- wait = d .pop ("wait " , UNSET )
192
+ join_id = d .pop ("joinId " , UNSET )
193
193
194
194
features = d .pop ("features" , UNSET )
195
195
196
196
aggregated_dataset_length = cls (
197
197
type = type ,
198
+ encrypted = encrypted ,
199
+ local_input_id = local_input_id ,
200
+ project_id = project_id ,
198
201
dp_policy = dp_policy ,
199
202
cohort_id = cohort_id ,
203
+ wait = wait ,
204
+ preprocessing_parameters = preprocessing_parameters ,
205
+ timeout = timeout ,
206
+ owner = owner ,
200
207
data_source_parameters = data_source_parameters ,
201
- encrypted = encrypted ,
202
- input_data_object = input_data_object ,
203
- join_id = join_id ,
204
208
local = local ,
205
209
local_input = local_input ,
206
- local_input_id = local_input_id ,
207
- owner = owner ,
208
- preprocessing_parameters = preprocessing_parameters ,
209
- project_id = project_id ,
210
- timeout = timeout ,
211
- wait = wait ,
210
+ input_data_object = input_data_object ,
211
+ join_id = join_id ,
212
212
features = features ,
213
213
)
214
214
0 commit comments