milenkovicm commented on code in PR #1361:
URL:
https://github.com/apache/datafusion-ballista/pull/1361#discussion_r2750718300
##########
ballista/scheduler/src/cluster/mod.rs:
##########
@@ -311,12 +313,15 @@ pub trait JobState: Send + Sync {
///
/// The job may not belong to the caller, and the graph may be updated
/// by another scheduler after this call returns.
- async fn get_execution_graph(&self, job_id: &str) ->
Result<Option<ExecutionGraph>>;
+ async fn get_execution_graph(
+ &self,
+ job_id: &str,
+ ) -> Result<Option<ExecutionGraphBox>>;
/// Persists the current state of an owned job.
Review Comment:
There used to be persistent backends but I have removed them as part of
refactor. Not sure what would be good case for them, and spark does not have
similar functionality.
So at the moment I have no plans for it, also if there is need users can
plug their own implementation
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
