steve/databricks-cli
steve
/
databricks-cli
mirror of https://github.com/databricks/cli.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

inline mocks

This commit is contained in:
Shreyas Goenka 2024-10-22 16:39:05 +02:00
parent f904ea4a92
commit 58f1ce9498
No known key found for this signature in database
GPG Key ID: 92A07DF49CCB0622
1 changed files with 63 additions and 67 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
bundle/run/job_test.go
View File

@ -130,7 +130,15 @@ func TestJobRunnerCancelWithNoActiveRuns(t *testing.T) {
require.NoError(t, err) require.NoError(t, err)
} }
func runJobRunnerRestartTest(t *testing.T, jobSettings *jobs.JobSettings) { func TestJobRunnerRestart(t *testing.T) {
for _, jobSettings := range []*jobs.JobSettings{
{},
{
Continuous: &jobs.Continuous{
PauseStatus: jobs.PauseStatusPaused,
},
},
} {
job := &resources.Job{ job := &resources.Job{
ID: "123", ID: "123",
JobSettings: jobSettings, JobSettings: jobSettings,
@ -195,18 +203,6 @@ func runJobRunnerRestartTest(t *testing.T, jobSettings *jobs.JobSettings) {
_, err := runner.Restart(ctx, &Options{}) _, err := runner.Restart(ctx, &Options{})
require.NoError(t, err) require.NoError(t, err)
} }
func TestJobRunnerRestart(t *testing.T) {
for _, jobSettings := range []*jobs.JobSettings{
{},
{
Continuous: &jobs.Continuous{
PauseStatus: jobs.PauseStatusPaused,
},
},
} {
runJobRunnerRestartTest(t, jobSettings)
}
} }
func TestJobRunnerRestartForContinuousUnpausedJobs(t *testing.T) { func TestJobRunnerRestartForContinuousUnpausedJobs(t *testing.T) {