Need the bucket from here
(store SparkFileStore)
| 359 | |
| 360 | // Need the bucket from here |
| 361 | func (db *DatabricksExecutor) PythonFileURI(store SparkFileStore) (filestore.Filepath, error) { |
| 362 | filePath := config.GetSparkRemoteScriptPath() |
| 363 | return store.CreateFilePath(filePath) |
| 364 | } |
| 365 | |
| 366 | func readAndUploadFile(filePath filestore.Filepath, storePath filestore.Filepath, store SparkFileStore) error { |
| 367 | fileExists, _ := store.Exists(storePath) |
no test coverage detected