Skip to content

Commit da60fab

Browse files
FlorentinDFlorentinD
committed
Default concurrency to None
1 parent e3b6ca5 commit da60fab

12 files changed

+58
-58
lines changed

‎graphdatascience/procedure_surface/api/community/clique_counting_endpoints.py‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ def mutate(
1616
self,
1717
G: GraphV2,
1818
mutate_property: str,
19-
concurrency: Optional[int] = 4,
19+
concurrency: Optional[int] = None,
2020
job_id: Optional[str] = None,
2121
log_progress: bool = True,
2222
node_labels: Optional[List[str]] = None,
@@ -59,7 +59,7 @@ def mutate(
5959
def stats(
6060
self,
6161
G: GraphV2,
62-
concurrency: Optional[int] = 4,
62+
concurrency: Optional[int] = None,
6363
job_id: Optional[str] = None,
6464
log_progress: bool = True,
6565
node_labels: Optional[List[str]] = None,
@@ -100,7 +100,7 @@ def stats(
100100
def stream(
101101
self,
102102
G: GraphV2,
103-
concurrency: Optional[int] = 4,
103+
concurrency: Optional[int] = None,
104104
job_id: Optional[str] = None,
105105
log_progress: bool = True,
106106
node_labels: Optional[List[str]] = None,
@@ -142,7 +142,7 @@ def write(
142142
self,
143143
G: GraphV2,
144144
write_property: str,
145-
concurrency: Optional[int] = 4,
145+
concurrency: Optional[int] = None,
146146
job_id: Optional[str] = None,
147147
log_progress: bool = True,
148148
node_labels: Optional[List[str]] = None,
@@ -188,7 +188,7 @@ def write(
188188
def estimate(
189189
self,
190190
G: Union[GraphV2, dict[str, Any]],
191-
concurrency: Optional[int] = 4,
191+
concurrency: Optional[int] = None,
192192
node_labels: Optional[List[str]] = None,
193193
relationship_types: Optional[List[str]] = None,
194194
) -> EstimationResult:

‎graphdatascience/procedure_surface/api/community/kmeans_endpoints.py‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ def mutate(
1919
mutate_property: str,
2020
*,
2121
compute_silhouette: Optional[bool] = False,
22-
concurrency: Optional[int] = 4,
22+
concurrency: Optional[int] = None,
2323
delta_threshold: Optional[float] = 0.05,
2424
initial_sampler: Optional[str] = "UNIFORM",
2525
job_id: Optional[str] = None,
@@ -90,7 +90,7 @@ def stats(
9090
node_property: str,
9191
*,
9292
compute_silhouette: Optional[bool] = False,
93-
concurrency: Optional[int] = 4,
93+
concurrency: Optional[int] = None,
9494
delta_threshold: Optional[float] = 0.05,
9595
initial_sampler: Optional[str] = "UNIFORM",
9696
job_id: Optional[str] = None,
@@ -159,7 +159,7 @@ def stream(
159159
node_property: str,
160160
*,
161161
compute_silhouette: Optional[bool] = False,
162-
concurrency: Optional[int] = 4,
162+
concurrency: Optional[int] = None,
163163
delta_threshold: Optional[float] = 0.05,
164164
initial_sampler: Optional[str] = "UNIFORM",
165165
job_id: Optional[str] = None,
@@ -229,7 +229,7 @@ def write(
229229
write_property: str,
230230
*,
231231
compute_silhouette: Optional[bool] = False,
232-
concurrency: Optional[int] = 4,
232+
concurrency: Optional[int] = None,
233233
delta_threshold: Optional[float] = 0.05,
234234
initial_sampler: Optional[str] = "UNIFORM",
235235
job_id: Optional[str] = None,
@@ -303,7 +303,7 @@ def estimate(
303303
node_property: str,
304304
*,
305305
compute_silhouette: Optional[bool] = False,
306-
concurrency: Optional[int] = 4,
306+
concurrency: Optional[int] = None,
307307
delta_threshold: Optional[float] = 0.05,
308308
initial_sampler: Optional[str] = "UNIFORM",
309309
k: Optional[int] = 10,

‎graphdatascience/procedure_surface/api/community/labelpropagation_endpoints.py‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ def mutate(
1717
G: GraphV2,
1818
mutate_property: str,
1919
*,
20-
concurrency: Optional[int] = 4,
20+
concurrency: Optional[int] = None,
2121
consecutive_ids: Optional[bool] = False,
2222
job_id: Optional[str] = None,
2323
log_progress: bool = True,
@@ -76,7 +76,7 @@ def stats(
7676
self,
7777
G: GraphV2,
7878
*,
79-
concurrency: Optional[int] = 4,
79+
concurrency: Optional[int] = None,
8080
consecutive_ids: Optional[bool] = False,
8181
job_id: Optional[str] = None,
8282
log_progress: bool = True,
@@ -133,7 +133,7 @@ def stream(
133133
self,
134134
G: GraphV2,
135135
*,
136-
concurrency: Optional[int] = 4,
136+
concurrency: Optional[int] = None,
137137
consecutive_ids: Optional[bool] = False,
138138
job_id: Optional[str] = None,
139139
log_progress: bool = True,
@@ -194,7 +194,7 @@ def write(
194194
G: GraphV2,
195195
write_property: str,
196196
*,
197-
concurrency: Optional[int] = 4,
197+
concurrency: Optional[int] = None,
198198
consecutive_ids: Optional[bool] = False,
199199
job_id: Optional[str] = None,
200200
log_progress: bool = True,
@@ -259,7 +259,7 @@ def estimate(
259259
self,
260260
G: Union[GraphV2, dict[str, Any]],
261261
*,
262-
concurrency: Optional[int] = 4,
262+
concurrency: Optional[int] = None,
263263
consecutive_ids: Optional[bool] = False,
264264
max_iterations: Optional[int] = 10,
265265
node_labels: Optional[List[str]] = None,

‎graphdatascience/procedure_surface/api/community/leiden_endpoints.py‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ def mutate(
1717
G: GraphV2,
1818
mutate_property: str,
1919
*,
20-
concurrency: Optional[int] = 4,
20+
concurrency: Optional[int] = None,
2121
consecutive_ids: Optional[bool] = False,
2222
gamma: Optional[float] = 1.0,
2323
include_intermediate_communities: Optional[bool] = False,
@@ -87,7 +87,7 @@ def stats(
8787
self,
8888
G: GraphV2,
8989
*,
90-
concurrency: Optional[int] = 4,
90+
concurrency: Optional[int] = None,
9191
consecutive_ids: Optional[bool] = False,
9292
gamma: Optional[float] = 1.0,
9393
include_intermediate_communities: Optional[bool] = False,
@@ -155,7 +155,7 @@ def stream(
155155
self,
156156
G: GraphV2,
157157
*,
158-
concurrency: Optional[int] = 4,
158+
concurrency: Optional[int] = None,
159159
consecutive_ids: Optional[bool] = False,
160160
gamma: Optional[float] = 1.0,
161161
include_intermediate_communities: Optional[bool] = False,
@@ -227,7 +227,7 @@ def write(
227227
G: GraphV2,
228228
write_property: str,
229229
*,
230-
concurrency: Optional[int] = 4,
230+
concurrency: Optional[int] = None,
231231
consecutive_ids: Optional[bool] = False,
232232
gamma: Optional[float] = 1.0,
233233
include_intermediate_communities: Optional[bool] = False,
@@ -291,7 +291,7 @@ def write(
291291
The username to attribute the procedure run to
292292
write_concurrency : Optional[int], default=None
293293
The number of concurrent threads for writing
294-
294+
295295
Returns
296296
-------
297297
LeidenWriteResult
@@ -303,7 +303,7 @@ def estimate(
303303
self,
304304
G: Union[GraphV2, dict[str, Any]],
305305
*,
306-
concurrency: Optional[int] = 4,
306+
concurrency: Optional[int] = None,
307307
consecutive_ids: Optional[bool] = False,
308308
gamma: Optional[float] = 1.0,
309309
include_intermediate_communities: Optional[bool] = False,

‎graphdatascience/procedure_surface/arrow/clique_counting_arrow_endpoints.py‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ def mutate(
3131
self,
3232
G: GraphV2,
3333
mutate_property: str,
34-
concurrency: Optional[int] = 4,
34+
concurrency: Optional[int] = None,
3535
job_id: Optional[str] = None,
3636
log_progress: bool = True,
3737
node_labels: Optional[List[str]] = None,
@@ -59,7 +59,7 @@ def mutate(
5959
def stats(
6060
self,
6161
G: GraphV2,
62-
concurrency: Optional[int] = 4,
62+
concurrency: Optional[int] = None,
6363
job_id: Optional[str] = None,
6464
log_progress: bool = True,
6565
node_labels: Optional[List[str]] = None,
@@ -87,7 +87,7 @@ def stats(
8787
def stream(
8888
self,
8989
G: GraphV2,
90-
concurrency: Optional[int] = 4,
90+
concurrency: Optional[int] = None,
9191
job_id: Optional[str] = None,
9292
log_progress: bool = True,
9393
node_labels: Optional[List[str]] = None,
@@ -112,7 +112,7 @@ def write(
112112
self,
113113
G: GraphV2,
114114
write_property: str,
115-
concurrency: Optional[int] = 4,
115+
concurrency: Optional[int] = None,
116116
job_id: Optional[str] = None,
117117
log_progress: bool = True,
118118
node_labels: Optional[List[str]] = None,

‎graphdatascience/procedure_surface/arrow/kmeans_arrow_endpoints.py‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ def mutate(
3434
mutate_property: str,
3535
*,
3636
compute_silhouette: Optional[bool] = False,
37-
concurrency: Optional[int] = 4,
37+
concurrency: Optional[int] = None,
3838
delta_threshold: Optional[float] = 0.05,
3939
initial_sampler: Optional[str] = "UNIFORM",
4040
job_id: Optional[str] = None,
@@ -79,7 +79,7 @@ def stats(
7979
node_property: str,
8080
*,
8181
compute_silhouette: Optional[bool] = False,
82-
concurrency: Optional[int] = 4,
82+
concurrency: Optional[int] = None,
8383
delta_threshold: Optional[float] = 0.05,
8484
initial_sampler: Optional[str] = "UNIFORM",
8585
job_id: Optional[str] = None,
@@ -124,7 +124,7 @@ def stream(
124124
node_property: str,
125125
*,
126126
compute_silhouette: Optional[bool] = False,
127-
concurrency: Optional[int] = 4,
127+
concurrency: Optional[int] = None,
128128
delta_threshold: Optional[float] = 0.05,
129129
initial_sampler: Optional[str] = "UNIFORM",
130130
job_id: Optional[str] = None,
@@ -168,7 +168,7 @@ def write(
168168
write_property: str,
169169
*,
170170
compute_silhouette: Optional[bool] = False,
171-
concurrency: Optional[int] = 4,
171+
concurrency: Optional[int] = None,
172172
delta_threshold: Optional[float] = 0.05,
173173
initial_sampler: Optional[str] = "UNIFORM",
174174
job_id: Optional[str] = None,

‎graphdatascience/procedure_surface/arrow/labelpropagation_arrow_endpoints.py‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ def mutate(
3232
G: GraphV2,
3333
mutate_property: str,
3434
*,
35-
concurrency: Optional[int] = 4,
35+
concurrency: Optional[int] = None,
3636
consecutive_ids: Optional[bool] = False,
3737
job_id: Optional[str] = None,
3838
log_progress: bool = True,
@@ -71,7 +71,7 @@ def stats(
7171
self,
7272
G: GraphV2,
7373
*,
74-
concurrency: Optional[int] = 4,
74+
concurrency: Optional[int] = None,
7575
consecutive_ids: Optional[bool] = False,
7676
job_id: Optional[str] = None,
7777
log_progress: bool = True,
@@ -110,7 +110,7 @@ def stream(
110110
self,
111111
G: GraphV2,
112112
*,
113-
concurrency: Optional[int] = 4,
113+
concurrency: Optional[int] = None,
114114
consecutive_ids: Optional[bool] = False,
115115
job_id: Optional[str] = None,
116116
log_progress: bool = True,
@@ -148,7 +148,7 @@ def write(
148148
G: GraphV2,
149149
write_property: str,
150150
*,
151-
concurrency: Optional[int] = 4,
151+
concurrency: Optional[int] = None,
152152
consecutive_ids: Optional[bool] = False,
153153
job_id: Optional[str] = None,
154154
log_progress: bool = True,
@@ -190,7 +190,7 @@ def estimate(
190190
self,
191191
G: Union[GraphV2, dict[str, Any]],
192192
*,
193-
concurrency: Optional[int] = 4,
193+
concurrency: Optional[int] = None,
194194
consecutive_ids: Optional[bool] = False,
195195
max_iterations: Optional[int] = 10,
196196
node_labels: Optional[List[str]] = None,

‎graphdatascience/procedure_surface/arrow/leiden_arrow_endpoints.py‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ def mutate(
3333
G: GraphV2,
3434
mutate_property: str,
3535
*,
36-
concurrency: Optional[int] = 4,
36+
concurrency: Optional[int] = None,
3737
consecutive_ids: Optional[bool] = False,
3838
gamma: Optional[float] = 1.0,
3939
include_intermediate_communities: Optional[bool] = False,
@@ -78,7 +78,7 @@ def stats(
7878
self,
7979
G: GraphV2,
8080
*,
81-
concurrency: Optional[int] = 4,
81+
concurrency: Optional[int] = None,
8282
consecutive_ids: Optional[bool] = False,
8383
gamma: Optional[float] = 1.0,
8484
include_intermediate_communities: Optional[bool] = False,
@@ -123,7 +123,7 @@ def stream(
123123
self,
124124
G: GraphV2,
125125
*,
126-
concurrency: Optional[int] = 4,
126+
concurrency: Optional[int] = None,
127127
consecutive_ids: Optional[bool] = False,
128128
gamma: Optional[float] = 1.0,
129129
include_intermediate_communities: Optional[bool] = False,
@@ -169,7 +169,7 @@ def write(
169169
G: GraphV2,
170170
write_property: str,
171171
*,
172-
concurrency: Optional[int] = 4,
172+
concurrency: Optional[int] = None,
173173
consecutive_ids: Optional[bool] = False,
174174
gamma: Optional[float] = 1.0,
175175
include_intermediate_communities: Optional[bool] = False,

‎graphdatascience/procedure_surface/cypher/clique_counting_cypher_endpoints.py‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ def mutate(
3030
self,
3131
G: GraphV2,
3232
mutate_property: str,
33-
concurrency: Optional[int] = 4,
33+
concurrency: Optional[int] = None,
3434
job_id: Optional[str] = None,
3535
log_progress: bool = True,
3636
node_labels: Optional[List[str]] = None,
@@ -61,7 +61,7 @@ def mutate(
6161
def stats(
6262
self,
6363
G: GraphV2,
64-
concurrency: Optional[int] = 4,
64+
concurrency: Optional[int] = None,
6565
job_id: Optional[str] = None,
6666
log_progress: bool = True,
6767
node_labels: Optional[List[str]] = None,
@@ -91,7 +91,7 @@ def stats(
9191
def stream(
9292
self,
9393
G: GraphV2,
94-
concurrency: Optional[int] = 4,
94+
concurrency: Optional[int] = None,
9595
job_id: Optional[str] = None,
9696
log_progress: bool = True,
9797
node_labels: Optional[List[str]] = None,
@@ -120,7 +120,7 @@ def write(
120120
self,
121121
G: GraphV2,
122122
write_property: str,
123-
concurrency: Optional[int] = 4,
123+
concurrency: Optional[int] = None,
124124
job_id: Optional[str] = None,
125125
log_progress: bool = True,
126126
node_labels: Optional[List[str]] = None,
@@ -153,7 +153,7 @@ def write(
153153
def estimate(
154154
self,
155155
G: Union[GraphV2, dict[str, Any]],
156-
concurrency: Optional[int] = 4,
156+
concurrency: Optional[int] = None,
157157
node_labels: Optional[List[str]] = None,
158158
relationship_types: Optional[List[str]] = None,
159159
) -> EstimationResult:

0 commit comments

Comments
 (0)