Skip to content

Commit e76fb09

Browse files
FlorentinDFlorentinD
committed
Use typed concurrency and job_id instead of Any
1 parent 9039753 commit e76fb09

30 files changed

+168
-168
lines changed

‎graphdatascience/procedure_surface/api/catalog/scale_properties_endpoints.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,8 @@ def mutate(
2424
sudo: bool = False,
2525
log_progress: bool = True,
2626
username: str | None = None,
27-
concurrency: Any | None = None,
28-
job_id: Any | None = None,
27+
concurrency: int | None = None,
28+
job_id: str | None = None,
2929
) -> ScalePropertiesMutateResult:
3030
"""
3131
Runs the Scale Properties algorithm and stores the results in the graph catalog as a new node property.

‎graphdatascience/procedure_surface/api/centrality/articulationpoints_endpoints.py‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@ def mutate(
2222
sudo: bool = False,
2323
log_progress: bool = True,
2424
username: str | None = None,
25-
concurrency: Any | None = None,
26-
job_id: Any | None = None,
25+
concurrency: int | None = None,
26+
job_id: str | None = None,
2727
) -> ArticulationPointsMutateResult:
2828
"""
2929
Runs the Articulation Points algorithm and stores the results in the graph catalog as a new node property.
@@ -66,8 +66,8 @@ def stats(
6666
sudo: bool = False,
6767
log_progress: bool = True,
6868
username: str | None = None,
69-
concurrency: Any | None = None,
70-
job_id: Any | None = None,
69+
concurrency: int | None = None,
70+
job_id: str | None = None,
7171
) -> ArticulationPointsStatsResult:
7272
"""
7373
Runs the Articulation Points algorithm and returns result statistics without storing the results.
@@ -108,8 +108,8 @@ def stream(
108108
sudo: bool = False,
109109
log_progress: bool = True,
110110
username: str | None = None,
111-
concurrency: Any | None = None,
112-
job_id: Any | None = None,
111+
concurrency: int | None = None,
112+
job_id: str | None = None,
113113
) -> DataFrame:
114114
"""
115115
Executes the ArticulationPoints algorithm and returns results as a stream.
@@ -151,8 +151,8 @@ def write(
151151
sudo: bool = False,
152152
log_progress: bool = True,
153153
username: str | None = None,
154-
concurrency: Any | None = None,
155-
job_id: Any | None = None,
154+
concurrency: int | None = None,
155+
job_id: str | None = None,
156156
write_concurrency: int | None = None,
157157
) -> ArticulationPointsWriteResult:
158158
"""
@@ -195,7 +195,7 @@ def estimate(
195195
G: GraphV2 | dict[str, Any],
196196
relationship_types: list[str] = ALL_TYPES,
197197
node_labels: list[str] = ALL_LABELS,
198-
concurrency: Any | None = None,
198+
concurrency: int | None = None,
199199
) -> EstimationResult:
200200
"""
201201
Estimate the memory consumption of an algorithm run.

‎graphdatascience/procedure_surface/api/centrality/betweenness_endpoints.py‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,8 @@ def mutate(
2424
sudo: bool = False,
2525
log_progress: bool = True,
2626
username: str | None = None,
27-
concurrency: Any | None = None,
28-
job_id: Any | None = None,
27+
concurrency: int | None = None,
28+
job_id: str | None = None,
2929
relationship_weight_property: str | None = None,
3030
) -> BetweennessMutateResult:
3131
"""
@@ -80,8 +80,8 @@ def stats(
8080
sudo: bool = False,
8181
log_progress: bool = True,
8282
username: str | None = None,
83-
concurrency: Any | None = None,
84-
job_id: Any | None = None,
83+
concurrency: int | None = None,
84+
job_id: str | None = None,
8585
relationship_weight_property: str | None = None,
8686
) -> BetweennessStatsResult:
8787
"""
@@ -134,8 +134,8 @@ def stream(
134134
sudo: bool = False,
135135
log_progress: bool = True,
136136
username: str | None = None,
137-
concurrency: Any | None = None,
138-
job_id: Any | None = None,
137+
concurrency: int | None = None,
138+
job_id: str | None = None,
139139
relationship_weight_property: str | None = None,
140140
) -> DataFrame:
141141
"""
@@ -184,10 +184,10 @@ def write(
184184
sudo: bool = False,
185185
log_progress: bool = True,
186186
username: str | None = None,
187-
concurrency: Any | None = None,
188-
job_id: Any | None = None,
187+
concurrency: int | None = None,
188+
job_id: str | None = None,
189189
relationship_weight_property: str | None = None,
190-
write_concurrency: Any | None = None,
190+
write_concurrency: int | None = None,
191191
) -> BetweennessWriteResult:
192192
"""
193193
Runs the Betweenness Centrality algorithm and stores the result in the Neo4j database as a new node property.
@@ -240,7 +240,7 @@ def estimate(
240240
sampling_seed: int | None = None,
241241
relationship_types: list[str] = ALL_TYPES,
242242
node_labels: list[str] = ALL_LABELS,
243-
concurrency: Any | None = None,
243+
concurrency: int | None = None,
244244
relationship_weight_property: str | None = None,
245245
) -> EstimationResult:
246246
"""

‎graphdatascience/procedure_surface/api/centrality/closeness_endpoints.py‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -170,8 +170,8 @@ def write(
170170
sudo: bool = False,
171171
log_progress: bool = True,
172172
username: str | None = None,
173-
concurrency: Any | None = None,
174-
job_id: Any | None = None,
173+
concurrency: int | None = None,
174+
job_id: str | None = None,
175175
write_concurrency: int | None = None,
176176
) -> ClosenessWriteResult:
177177
"""
@@ -221,7 +221,7 @@ def estimate(
221221
use_wasserman_faust: bool = False,
222222
relationship_types: list[str] = ALL_TYPES,
223223
node_labels: list[str] = ALL_LABELS,
224-
concurrency: Any | None = None,
224+
concurrency: int | None = None,
225225
) -> EstimationResult:
226226
"""
227227
Estimate the memory consumption of an algorithm run.

‎graphdatascience/procedure_surface/api/centrality/closeness_harmonic_endpoints.py‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@ def mutate(
2222
sudo: bool = False,
2323
log_progress: bool = True,
2424
username: str | None = None,
25-
concurrency: Any | None = None,
26-
job_id: Any | None = None,
25+
concurrency: int | None = None,
26+
job_id: str | None = None,
2727
) -> ClosenessHarmonicMutateResult:
2828
"""
2929
Runs the Harmonic Centrality algorithm and stores the results in the graph catalog as a new node property.
@@ -69,8 +69,8 @@ def stats(
6969
sudo: bool = False,
7070
log_progress: bool = True,
7171
username: str | None = None,
72-
concurrency: Any | None = None,
73-
job_id: Any | None = None,
72+
concurrency: int | None = None,
73+
job_id: str | None = None,
7474
) -> ClosenessHarmonicStatsResult:
7575
"""
7676
Runs the Harmonic Centrality algorithm and returns result statistics without storing the results.
@@ -116,8 +116,8 @@ def stream(
116116
sudo: bool = False,
117117
log_progress: bool = True,
118118
username: str | None = None,
119-
concurrency: Any | None = None,
120-
job_id: Any | None = None,
119+
concurrency: int | None = None,
120+
job_id: str | None = None,
121121
) -> DataFrame:
122122
"""
123123
Executes the Harmonic Closeness Centrality algorithm and returns a stream of results.
@@ -159,8 +159,8 @@ def write(
159159
sudo: bool = False,
160160
log_progress: bool = True,
161161
username: str | None = None,
162-
concurrency: Any | None = None,
163-
job_id: Any | None = None,
162+
concurrency: int | None = None,
163+
job_id: str | None = None,
164164
write_concurrency: int | None = None,
165165
) -> ClosenessHarmonicWriteResult:
166166
"""
@@ -208,7 +208,7 @@ def estimate(
208208
G: GraphV2 | dict[str, Any],
209209
relationship_types: list[str] = ALL_TYPES,
210210
node_labels: list[str] = ALL_LABELS,
211-
concurrency: Any | None = None,
211+
concurrency: int | None = None,
212212
) -> EstimationResult:
213213
"""
214214
Estimate the memory consumption of a Harmonic Closeness Centrality algorithm run.

‎graphdatascience/procedure_surface/api/centrality/degree_endpoints.py‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,8 @@ def mutate(
2323
sudo: bool = False,
2424
log_progress: bool = True,
2525
username: str | None = None,
26-
concurrency: Any | None = None,
27-
job_id: Any | None = None,
26+
concurrency: int | None = None,
27+
job_id: str | None = None,
2828
relationship_weight_property: str | None = None,
2929
) -> DegreeMutateResult:
3030
"""
@@ -77,8 +77,8 @@ def stats(
7777
sudo: bool = False,
7878
log_progress: bool = True,
7979
username: str | None = None,
80-
concurrency: Any | None = None,
81-
job_id: Any | None = None,
80+
concurrency: int | None = None,
81+
job_id: str | None = None,
8282
relationship_weight_property: str | None = None,
8383
) -> DegreeStatsResult:
8484
"""
@@ -129,8 +129,8 @@ def stream(
129129
sudo: bool = False,
130130
log_progress: bool = True,
131131
username: str | None = None,
132-
concurrency: Any | None = None,
133-
job_id: Any | None = None,
132+
concurrency: int | None = None,
133+
job_id: str | None = None,
134134
relationship_weight_property: str | None = None,
135135
) -> DataFrame:
136136
"""
@@ -184,8 +184,8 @@ def write(
184184
sudo: bool = False,
185185
log_progress: bool = True,
186186
username: str | None = None,
187-
concurrency: Any | None = None,
188-
job_id: Any | None = None,
187+
concurrency: int | None = None,
188+
job_id: str | None = None,
189189
relationship_weight_property: str | None = None,
190190
write_concurrency: int | None = None,
191191
) -> DegreeWriteResult:
@@ -238,7 +238,7 @@ def estimate(
238238
orientation: str = "NATURAL",
239239
relationship_types: list[str] = ALL_TYPES,
240240
node_labels: list[str] = ALL_LABELS,
241-
concurrency: Any | None = None,
241+
concurrency: int | None = None,
242242
relationship_weight_property: str | None = None,
243243
) -> EstimationResult:
244244
"""

‎graphdatascience/procedure_surface/api/centrality/eigenvector_endpoints.py‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -28,8 +28,8 @@ def mutate(
2828
sudo: bool = False,
2929
log_progress: bool = True,
3030
username: str | None = None,
31-
concurrency: Any | None = None,
32-
job_id: Any | None = None,
31+
concurrency: int | None = None,
32+
job_id: str | None = None,
3333
) -> EigenvectorMutateResult:
3434
"""
3535
Runs the Eigenvector Centrality algorithm and stores the results in the graph catalog as a new node property.
@@ -96,8 +96,8 @@ def stats(
9696
sudo: bool = False,
9797
log_progress: bool = True,
9898
username: str | None = None,
99-
concurrency: Any | None = None,
100-
job_id: Any | None = None,
99+
concurrency: int | None = None,
100+
job_id: str | None = None,
101101
) -> EigenvectorStatsResult:
102102
"""
103103
Runs the Eigenvector Centrality algorithm and returns result statistics without storing the results.
@@ -162,8 +162,8 @@ def stream(
162162
sudo: bool = False,
163163
log_progress: bool = True,
164164
username: str | None = None,
165-
concurrency: Any | None = None,
166-
job_id: Any | None = None,
165+
concurrency: int | None = None,
166+
job_id: str | None = None,
167167
) -> DataFrame:
168168
"""
169169
Executes the Eigenvector Centrality algorithm and returns a stream of results.
@@ -224,8 +224,8 @@ def write(
224224
sudo: bool = False,
225225
log_progress: bool = True,
226226
username: str | None = None,
227-
concurrency: Any | None = None,
228-
job_id: Any | None = None,
227+
concurrency: int | None = None,
228+
job_id: str | None = None,
229229
write_concurrency: int | None = None,
230230
) -> EigenvectorWriteResult:
231231
"""
@@ -292,7 +292,7 @@ def estimate(
292292
relationship_weight_property: str | None = None,
293293
relationship_types: list[str] = ALL_TYPES,
294294
node_labels: list[str] = ALL_LABELS,
295-
concurrency: Any | None = None,
295+
concurrency: int | None = None,
296296
) -> EstimationResult:
297297
"""
298298
Estimate the memory consumption of an algorithm run.

‎graphdatascience/procedure_surface/api/centrality/pagerank_endpoints.py‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,8 @@ def mutate(
2727
sudo: bool = False,
2828
log_progress: bool = True,
2929
username: str | None = None,
30-
concurrency: Any | None = None,
31-
job_id: Any | None = None,
30+
concurrency: int | None = None,
31+
job_id: str | None = None,
3232
relationship_weight_property: str | None = None,
3333
source_nodes: Any | None = None,
3434
) -> PageRankMutateResult:
@@ -95,8 +95,8 @@ def stats(
9595
sudo: bool = False,
9696
log_progress: bool = True,
9797
username: str | None = None,
98-
concurrency: Any | None = None,
99-
job_id: Any | None = None,
98+
concurrency: int | None = None,
99+
job_id: str | None = None,
100100
relationship_weight_property: str | None = None,
101101
source_nodes: Any | None = None,
102102
) -> PageRankStatsResult:
@@ -161,8 +161,8 @@ def stream(
161161
sudo: bool = False,
162162
log_progress: bool = True,
163163
username: str | None = None,
164-
concurrency: Any | None = None,
165-
job_id: Any | None = None,
164+
concurrency: int | None = None,
165+
job_id: str | None = None,
166166
relationship_weight_property: str | None = None,
167167
source_nodes: Any | None = None,
168168
) -> DataFrame:
@@ -225,8 +225,8 @@ def write(
225225
sudo: bool = False,
226226
log_progress: bool = True,
227227
username: str | None = None,
228-
concurrency: Any | None = None,
229-
job_id: Any | None = None,
228+
concurrency: int | None = None,
229+
job_id: str | None = None,
230230
relationship_weight_property: str | None = None,
231231
source_nodes: Any | None = None,
232232
write_concurrency: int | None = None,
@@ -293,7 +293,7 @@ def estimate(
293293
scaler: str | dict[str, str | int | float] | ScalerConfig = "NONE",
294294
relationship_types: list[str] = ALL_TYPES,
295295
node_labels: list[str] = ALL_LABELS,
296-
concurrency: Any | None = None,
296+
concurrency: int | None = None,
297297
relationship_weight_property: str | None = None,
298298
source_nodes: Any | None = None,
299299
) -> EstimationResult:

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ def mutate(
2727
concurrency: int | None = None,
2828
log_progress: bool = True,
2929
sudo: bool = False,
30-
job_id: Any | None = None,
30+
job_id: str | None = None,
3131
username: str | None = None,
3232
) -> HdbscanMutateResult:
3333
"""
@@ -85,7 +85,7 @@ def stats(
8585
concurrency: int | None = None,
8686
log_progress: bool = True,
8787
sudo: bool = False,
88-
job_id: Any | None = None,
88+
job_id: str | None = None,
8989
username: str | None = None,
9090
) -> HdbscanStatsResult:
9191
"""
@@ -141,7 +141,7 @@ def stream(
141141
concurrency: int | None = None,
142142
log_progress: bool = True,
143143
sudo: bool = False,
144-
job_id: Any | None = None,
144+
job_id: str | None = None,
145145
username: str | None = None,
146146
) -> DataFrame:
147147
"""
@@ -198,7 +198,7 @@ def write(
198198
concurrency: int | None = None,
199199
log_progress: bool = True,
200200
sudo: bool = False,
201-
job_id: Any | None = None,
201+
job_id: str | None = None,
202202
username: str | None = None,
203203
write_concurrency: int | None = None,
204204
) -> HdbscanWriteResult:

0 commit comments

Comments
 (0)