Skip to content

Commit 65ad5ff

Browse files
FlorentinDFlorentinD
committed
Pass log_progress to query_runner and clarify default value
query_runner already will do a progress bar using listProgress internally
1 parent 9f94402 commit 65ad5ff

File tree

73 files changed

+444
-336
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

73 files changed

+444
-336
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ def rwr(
2626
relationship_types: Optional[List[str]] = None,
2727
node_labels: Optional[List[str]] = None,
2828
sudo: Optional[bool] = None,
29-
log_progress: Optional[bool] = None,
29+
log_progress: bool = True,
3030
username: Optional[str] = None,
3131
concurrency: Optional[int] = None,
3232
job_id: Optional[str] = None,
@@ -99,7 +99,7 @@ def cnarw(
9999
relationship_types: Optional[List[str]] = None,
100100
node_labels: Optional[List[str]] = None,
101101
sudo: Optional[bool] = None,
102-
log_progress: Optional[bool] = None,
102+
log_progress: bool = True,
103103
username: Optional[str] = None,
104104
concurrency: Optional[int] = None,
105105
job_id: Optional[str] = None,

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ def mutate(
1616
*,
1717
node_filter: str,
1818
sudo: Optional[bool] = None,
19-
log_progress: Optional[bool] = None,
19+
log_progress: bool = True,
2020
username: Optional[str] = None,
2121
concurrency: Optional[Any] = None,
2222
write_concurrency: Optional[Any] = None,
@@ -60,7 +60,7 @@ def write(
6060
*,
6161
node_filter: str,
6262
sudo: Optional[bool] = None,
63-
log_progress: Optional[bool] = None,
63+
log_progress: bool = True,
6464
username: Optional[str] = None,
6565
concurrency: Optional[Any] = None,
6666
write_concurrency: Optional[Any] = None,

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ def stream(
2121
node_labels: Optional[List[str]] = None,
2222
concurrency: Optional[Any] = None,
2323
sudo: Optional[bool] = None,
24-
log_progress: Optional[bool] = None,
24+
log_progress: bool = True,
2525
username: Optional[str] = None,
2626
job_id: Optional[Any] = None,
2727
db_node_properties: Optional[List[str]] = None,
@@ -68,7 +68,7 @@ def write(
6868
concurrency: Optional[Any] = None,
6969
write_concurrency: Optional[Any] = None,
7070
sudo: Optional[bool] = None,
71-
log_progress: Optional[bool] = None,
71+
log_progress: bool = True,
7272
username: Optional[str] = None,
7373
job_id: Optional[Any] = None,
7474
) -> NodePropertiesWriteResult:
@@ -112,7 +112,7 @@ def drop(
112112
fail_if_missing: Optional[bool] = None,
113113
concurrency: Optional[Any] = None,
114114
sudo: Optional[bool] = None,
115-
log_progress: Optional[bool] = None,
115+
log_progress: bool = True,
116116
username: Optional[str] = None,
117117
job_id: Optional[Any] = None,
118118
) -> NodePropertiesDropResult:

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ def stream(
2121
*,
2222
concurrency: Optional[Any] = None,
2323
sudo: Optional[bool] = None,
24-
log_progress: Optional[bool] = None,
24+
log_progress: bool = True,
2525
username: Optional[str] = None,
2626
) -> DataFrame:
2727
"""
@@ -61,7 +61,7 @@ def write(
6161
concurrency: Optional[Any] = None,
6262
write_concurrency: Optional[Any] = None,
6363
sudo: Optional[bool] = None,
64-
log_progress: Optional[bool] = None,
64+
log_progress: bool = True,
6565
username: Optional[str] = None,
6666
job_id: Optional[Any] = None,
6767
) -> RelationshipsWriteResult:
@@ -129,7 +129,7 @@ def index_inverse(
129129
*,
130130
concurrency: Optional[Any] = None,
131131
sudo: Optional[bool] = None,
132-
log_progress: Optional[bool] = None,
132+
log_progress: bool = True,
133133
username: Optional[str] = None,
134134
job_id: Optional[Any] = None,
135135
) -> RelationshipsInverseIndexResult:
@@ -169,7 +169,7 @@ def to_undirected(
169169
aggregation: Optional[Union[Aggregation, dict[str, Aggregation]]] = None,
170170
concurrency: Optional[Any] = None,
171171
sudo: Optional[bool] = None,
172-
log_progress: Optional[bool] = None,
172+
log_progress: bool = True,
173173
username: Optional[str] = None,
174174
job_id: Optional[Any] = None,
175175
) -> RelationshipsToUndirectedResult:

‎graphdatascience/procedure_surface/api/catalog_endpoints.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ def generate(
8989
read_concurrency: Optional[int] = None,
9090
job_id: Optional[str] = None,
9191
sudo: Optional[bool] = None,
92-
log_progress: Optional[bool] = None,
92+
log_progress: bool = True,
9393
username: Optional[str] = None,
9494
) -> GraphWithGenerationStats:
9595
"""

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ def mutate(
2323
relationship_types: Optional[List[str]] = None,
2424
node_labels: Optional[List[str]] = None,
2525
sudo: Optional[bool] = None,
26-
log_progress: Optional[bool] = None,
26+
log_progress: bool = True,
2727
username: Optional[str] = None,
2828
concurrency: Optional[Any] = None,
2929
job_id: Optional[Any] = None,
@@ -87,7 +87,7 @@ def stats(
8787
relationship_types: Optional[List[str]] = None,
8888
node_labels: Optional[List[str]] = None,
8989
sudo: Optional[bool] = None,
90-
log_progress: Optional[bool] = None,
90+
log_progress: bool = True,
9191
username: Optional[str] = None,
9292
concurrency: Optional[Any] = None,
9393
job_id: Optional[Any] = None,
@@ -149,7 +149,7 @@ def stream(
149149
relationship_types: Optional[List[str]] = None,
150150
node_labels: Optional[List[str]] = None,
151151
sudo: Optional[bool] = None,
152-
log_progress: Optional[bool] = None,
152+
log_progress: bool = True,
153153
username: Optional[str] = None,
154154
concurrency: Optional[Any] = None,
155155
job_id: Optional[Any] = None,
@@ -208,7 +208,7 @@ def write(
208208
relationship_types: Optional[List[str]] = None,
209209
node_labels: Optional[List[str]] = None,
210210
sudo: Optional[bool] = None,
211-
log_progress: Optional[bool] = None,
211+
log_progress: bool = True,
212212
username: Optional[str] = None,
213213
concurrency: Optional[Any] = None,
214214
job_id: Optional[Any] = None,

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ def mutate(
1717
relationship_types: Optional[List[str]] = None,
1818
node_labels: Optional[List[str]] = None,
1919
sudo: Optional[bool] = None,
20-
log_progress: Optional[bool] = None,
20+
log_progress: bool = True,
2121
username: Optional[str] = None,
2222
concurrency: Optional[Any] = None,
2323
job_id: Optional[Any] = None,
@@ -61,7 +61,7 @@ def stats(
6161
relationship_types: Optional[List[str]] = None,
6262
node_labels: Optional[List[str]] = None,
6363
sudo: Optional[bool] = None,
64-
log_progress: Optional[bool] = None,
64+
log_progress: bool = True,
6565
username: Optional[str] = None,
6666
concurrency: Optional[Any] = None,
6767
job_id: Optional[Any] = None,
@@ -103,7 +103,7 @@ def stream(
103103
relationship_types: Optional[List[str]] = None,
104104
node_labels: Optional[List[str]] = None,
105105
sudo: Optional[bool] = None,
106-
log_progress: Optional[bool] = None,
106+
log_progress: bool = True,
107107
username: Optional[str] = None,
108108
concurrency: Optional[Any] = None,
109109
job_id: Optional[Any] = None,
@@ -146,7 +146,7 @@ def write(
146146
relationship_types: Optional[List[str]] = None,
147147
node_labels: Optional[List[str]] = None,
148148
sudo: Optional[bool] = None,
149-
log_progress: Optional[bool] = None,
149+
log_progress: bool = True,
150150
username: Optional[str] = None,
151151
concurrency: Optional[Any] = None,
152152
job_id: Optional[Any] = None,

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ def mutate(
2121
relationship_types: Optional[List[str]] = None,
2222
node_labels: Optional[List[str]] = None,
2323
sudo: Optional[bool] = None,
24-
log_progress: Optional[bool] = None,
24+
log_progress: bool = True,
2525
username: Optional[str] = None,
2626
concurrency: Optional[Any] = None,
2727
job_id: Optional[Any] = None,
@@ -77,7 +77,7 @@ def stats(
7777
relationship_types: Optional[List[str]] = None,
7878
node_labels: Optional[List[str]] = None,
7979
sudo: Optional[bool] = None,
80-
log_progress: Optional[bool] = None,
80+
log_progress: bool = True,
8181
username: Optional[str] = None,
8282
concurrency: Optional[Any] = None,
8383
job_id: Optional[Any] = None,
@@ -131,7 +131,7 @@ def stream(
131131
relationship_types: Optional[List[str]] = None,
132132
node_labels: Optional[List[str]] = None,
133133
sudo: Optional[bool] = None,
134-
log_progress: Optional[bool] = None,
134+
log_progress: bool = True,
135135
username: Optional[str] = None,
136136
concurrency: Optional[Any] = None,
137137
job_id: Optional[Any] = None,
@@ -181,7 +181,7 @@ def write(
181181
relationship_types: Optional[List[str]] = None,
182182
node_labels: Optional[List[str]] = None,
183183
sudo: Optional[bool] = None,
184-
log_progress: Optional[bool] = None,
184+
log_progress: bool = True,
185185
username: Optional[str] = None,
186186
concurrency: Optional[Any] = None,
187187
job_id: Optional[Any] = None,

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ def mutate(
2323
relationship_types: Optional[List[str]] = None,
2424
node_labels: Optional[List[str]] = None,
2525
sudo: Optional[bool] = None,
26-
log_progress: Optional[bool] = None,
26+
log_progress: bool = True,
2727
username: Optional[str] = None,
2828
concurrency: Optional[Any] = None,
2929
job_id: Optional[Any] = None,
@@ -80,7 +80,7 @@ def stats(
8080
relationship_types: Optional[List[str]] = None,
8181
node_labels: Optional[List[str]] = None,
8282
sudo: Optional[bool] = None,
83-
log_progress: Optional[bool] = None,
83+
log_progress: bool = True,
8484
username: Optional[str] = None,
8585
concurrency: Optional[Any] = None,
8686
job_id: Optional[Any] = None,
@@ -135,7 +135,7 @@ def stream(
135135
relationship_types: Optional[List[str]] = None,
136136
node_labels: Optional[List[str]] = None,
137137
sudo: Optional[bool] = None,
138-
log_progress: Optional[bool] = None,
138+
log_progress: bool = True,
139139
username: Optional[str] = None,
140140
concurrency: Optional[Any] = None,
141141
job_id: Optional[Any] = None,
@@ -191,7 +191,7 @@ def write(
191191
relationship_types: Optional[List[str]] = None,
192192
node_labels: Optional[List[str]] = None,
193193
sudo: Optional[bool] = None,
194-
log_progress: Optional[bool] = None,
194+
log_progress: bool = True,
195195
username: Optional[str] = None,
196196
concurrency: Optional[Any] = None,
197197
job_id: Optional[Any] = None,

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ def mutate(
2020
relationship_types: Optional[List[str]] = None,
2121
node_labels: Optional[List[str]] = None,
2222
sudo: Optional[bool] = None,
23-
log_progress: Optional[bool] = None,
23+
log_progress: bool = True,
2424
username: Optional[str] = None,
2525
concurrency: Optional[Any] = None,
2626
job_id: Optional[Any] = None,
@@ -71,7 +71,7 @@ def stats(
7171
relationship_types: Optional[List[str]] = None,
7272
node_labels: Optional[List[str]] = None,
7373
sudo: Optional[bool] = None,
74-
log_progress: Optional[bool] = None,
74+
log_progress: bool = True,
7575
username: Optional[str] = None,
7676
concurrency: Optional[Any] = None,
7777
job_id: Optional[Any] = None,
@@ -120,7 +120,7 @@ def stream(
120120
relationship_types: Optional[List[str]] = None,
121121
node_labels: Optional[List[str]] = None,
122122
sudo: Optional[bool] = None,
123-
log_progress: Optional[bool] = None,
123+
log_progress: bool = True,
124124
username: Optional[str] = None,
125125
concurrency: Optional[Any] = None,
126126
job_id: Optional[Any] = None,
@@ -167,7 +167,7 @@ def write(
167167
relationship_types: Optional[List[str]] = None,
168168
node_labels: Optional[List[str]] = None,
169169
sudo: Optional[bool] = None,
170-
log_progress: Optional[bool] = None,
170+
log_progress: bool = True,
171171
username: Optional[str] = None,
172172
concurrency: Optional[Any] = None,
173173
job_id: Optional[Any] = None,

0 commit comments

Comments
 (0)