Queries the status of the notebook execution.
Queries the status of the notebook execution.
Id of the notebook
Id of the execution to retrieve from PythonNotebookExecution response.
Lists the DB connection names (as registered in Chorus 'Data' tab) and ids for a specific workflow
Lists the DB connection names (as registered in Chorus 'Data' tab) and ids for a specific workflow
id of the current workflow
The list of Chorus DB data sources ChorusDBSourceInfo the workflow is connected to.
Equivalent to readWorkfileAsText(workfile.id)
Equivalent to readWorkfileAsText(workfile.id)
The file to download.
The contents of the file as a string.
Downloads the workfile with the referenced id from Chorus, and reads the content as a text file.
Downloads the workfile with the referenced id from Chorus, and reads the content as a text file.
Id of the file to download.
The contents of the file as a string.
Equivalent to readFunction)
Equivalent to readFunction)
The return type of the read function.
The file to download.
The function to apply to the file input stream.
The output of the readFunction applied to the downloaded file input stream.
Gets the workfile from Chorus as an input stream, applies the read function, closes the input stream and then returns the result of the read function.
Gets the workfile from Chorus as an input stream, applies the read function, closes the input stream and then returns the result of the read function.
The return type of the read function.
Id of the file to download.
The function to apply to the file input stream.
The output of the readFunction applied to the downloaded file input stream.
Runs a notebook by substituting the output path (and possibly input path(s)).
Runs a notebook by substituting the output path (and possibly input path(s)). This will only work if the notebook attribute "ready_to_execute" is true.
Id of the notebook to retrieve
name of the data source where inputs come from and where output will be stored
Optional SeqNotebookIOForExecution of inputs info for substitution in the notebook
Optional NotebookIOForExecution or single output substitution in the notebook
Optional Spark parameters to be substituted in notebook if Spark is used (e.g Map("spark.executor.instances" -> "2")
Runs a workfile and returns the workfile object if successful Note: this will not fail if the workfile exists but cannot be run (e.
Runs a workfile and returns the workfile object if successful Note: this will not fail if the workfile exists but cannot be run (e.g. if the notebook server is down, the query may appear successful). Hoping to change this behavior in future releases.