Skip to content

Implement JobHandle and use it in WCC#1057

Draft
DarthMax wants to merge 1 commit intomainfrom
async_api_spike
Draft

Implement JobHandle and use it in WCC#1057
DarthMax wants to merge 1 commit intomainfrom
async_api_spike

Conversation

@DarthMax
Copy link
Contributor

@DarthMax DarthMax commented Jan 23, 2026

ref GDSA-145

@netlify
Copy link

netlify bot commented Jan 23, 2026

Deploy Preview for neo4j-graph-data-science-client canceled.

Name Link
🔨 Latest commit f6f7a57
🔍 Latest deploy log https://app.netlify.com/projects/neo4j-graph-data-science-client/deploys/6973ac79319961000732f942

log_progress: bool = True,
) -> WriteBackResult:
if isinstance(property_overwrites, str):
# The remote write back procedure allows specifying a single overwrite. The key is ignored.
Copy link
Contributor

@RafalSkolasinski RafalSkolasinski Jan 30, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

And if user provides dict[str, str] are keys also ignored?

job_id: str,
remote_write_back_client: RemoteWriteBackClient | None = None,
):
super().__init__(arrow_client, job_id, remote_write_back_client=remote_write_back_client)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think due to multiple inheritance in this case only the init method of JobHandle will be called, so remote_write_back_client may not get set?

Copy link
Contributor

@FlorentinD FlorentinD left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I like the general api, only minor comments

threshold=threshold,
)

job_id = self._node_property_endpoints.run_job("v2/community.wcc", config)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

NIT: maybe we want to name the method start_job instead

self._client = client

def stream(self, G: GraphV2) -> DataFrame:
return JobClient().stream_results(self._client, G.name(), self._job_id)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

dont we need to check the status of the job before streaming?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants