Skip to content

Commit

Permalink
Split workflow definitions into sensible packages
Browse files Browse the repository at this point in the history
  • Loading branch information
@nfx
nfx committed Oct 30, 2024
1 parent 448ea6a commit c82cd0c
Show file tree
Hide file tree
Showing 71 changed files with 160 additions and 71 deletions.
3 changes: 2 additions & 1 deletion ...ph/intermediate/workflows/AutoScale.scala → ...ediate/workflows/clusters/AutoScale.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class AutoScale(maxWorkers: Option[Int], minWorkers: Option[Int] = None) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...ntermediate/workflows/AwsAttributes.scala → ...te/workflows/clusters/AwsAttributes.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute
import com.databricks.sdk.service.compute.{AwsAvailability, EbsVolumeType}

Expand Down
3 changes: 2 additions & 1 deletion ...ermediate/workflows/AzureAttributes.scala → .../workflows/clusters/AzureAttributes.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute
import com.databricks.sdk.service.compute.AzureAvailability

Expand Down
3 changes: 2 additions & 1 deletion ...intermediate/workflows/ClientsTypes.scala → ...ate/workflows/clusters/ClientsTypes.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class ClientsTypes(jobs: Boolean = false, notebooks: Boolean) extends JobNode {
Expand Down
4 changes: 3 additions & 1 deletion ...termediate/workflows/ClusterLogConf.scala → ...e/workflows/clusters/ClusterLogConf.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.sources.{DbfsStorageInfo, S3StorageInfo}
import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class ClusterLogConf(dbfs: Option[DbfsStorageInfo], s3: Option[S3StorageInfo] = None) extends JobNode {
Expand Down
4 changes: 3 additions & 1 deletion .../intermediate/workflows/ClusterSpec.scala → ...iate/workflows/clusters/ClusterSpec.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.labs.remorph.intermediate.workflows.libraries.Library
import com.databricks.sdk.service.jobs

case class ClusterSpec(
Expand Down
3 changes: 2 additions & 1 deletion ...rph/intermediate/workflows/DiskSpec.scala → ...mediate/workflows/clusters/DiskSpec.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class DiskSpec(
Expand Down
3 changes: 2 additions & 1 deletion ...rph/intermediate/workflows/DiskType.scala → ...mediate/workflows/clusters/DiskType.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute
import com.databricks.sdk.service.compute.{DiskTypeAzureDiskVolumeType, DiskTypeEbsVolumeType}

Expand Down
3 changes: 2 additions & 1 deletion ...ntermediate/workflows/GcpAttributes.scala → ...te/workflows/clusters/GcpAttributes.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute
import com.databricks.sdk.service.compute.GcpAvailability

Expand Down
4 changes: 3 additions & 1 deletion ...termediate/workflows/InitScriptInfo.scala → ...e/workflows/clusters/InitScriptInfo.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.sources.{Adlsgen2Info, DbfsStorageInfo, GcsStorageInfo, LocalFileInfo, S3StorageInfo, VolumesStorageInfo, WorkspaceStorageInfo}
import com.databricks.labs.remorph.intermediate.workflows._
import com.databricks.sdk.service.compute

case class InitScriptInfo(
Expand Down
3 changes: 2 additions & 1 deletion ...rmediate/workflows/LogAnalyticsInfo.scala → ...workflows/clusters/LogAnalyticsInfo.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class LogAnalyticsInfo(logAnalyticsPrimaryKey: Option[String], logAnalyticsWorkspaceId: Option[String] = None)
Expand Down
4 changes: 3 additions & 1 deletion ...termediate/workflows/NewClusterSpec.scala → ...e/workflows/clusters/NewClusterSpec.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.libraries.DockerImage
import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute
import com.databricks.sdk.service.compute.{DataSecurityMode, RuntimeEngine}

Expand Down
3 changes: 2 additions & 1 deletion ...intermediate/workflows/WorkloadType.scala → ...ate/workflows/clusters/WorkloadType.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.clusters

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class WorkloadType(clients: ClientsTypes) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion .../remorph/intermediate/workflows/Job.scala → ...rph/intermediate/workflows/jobs/Job.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs

case class Job(
Expand Down
4 changes: 3 additions & 1 deletion ...h/intermediate/workflows/JobCluster.scala → ...ermediate/workflows/jobs/JobCluster.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.labs.remorph.intermediate.workflows.clusters.ClusterSpec
import com.databricks.sdk.service.jobs

case class JobCluster(jobClusterKey: String, newCluster: ClusterSpec) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...ntermediate/workflows/JobDeployment.scala → ...ediate/workflows/jobs/JobDeployment.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs
import com.databricks.sdk.service.jobs.JobDeploymentKind

Expand Down
3 changes: 2 additions & 1 deletion ...ate/workflows/JobEmailNotifications.scala → ...orkflows/jobs/JobEmailNotifications.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs

case class JobEmailNotifications(
Expand Down
4 changes: 3 additions & 1 deletion ...termediate/workflows/JobEnvironment.scala → ...diate/workflows/jobs/JobEnvironment.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.labs.remorph.intermediate.workflows.libraries.Environment
import com.databricks.sdk.service.jobs

case class JobEnvironment(environmentKey: String, spec: Option[Environment] = None) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...e/workflows/JobNotificationSettings.scala → ...kflows/jobs/JobNotificationSettings.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs

case class JobNotificationSettings(noAlertForCanceledRuns: Boolean = false, noAlertForSkippedRuns: Boolean)
Expand Down
3 changes: 2 additions & 1 deletion ...intermediate/workflows/JobParameter.scala → ...mediate/workflows/jobs/JobParameter.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs

case class JobParameter(default: Option[String], name: Option[String], value: Option[String] = None) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...te/workflows/JobParameterDefinition.scala → ...rkflows/jobs/JobParameterDefinition.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs

case class JobParameterDefinition(name: String, default: String) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...rph/intermediate/workflows/JobRunAs.scala → ...ntermediate/workflows/jobs/JobRunAs.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs

case class JobRunAs(servicePrincipalName: Option[String], userName: Option[String] = None) extends JobNode {
Expand Down
7 changes: 6 additions & 1 deletion .../intermediate/workflows/JobSettings.scala → ...rmediate/workflows/jobs/JobSettings.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,10 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.schedules.{Continuous, CronSchedule, TriggerSettings}
import com.databricks.labs.remorph.intermediate.workflows.sources.GitSource
import com.databricks.labs.remorph.intermediate.workflows.tasks.Task
import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.labs.remorph.intermediate.workflows.webhooks.WebhookNotifications
import com.databricks.sdk.service.jobs
import com.databricks.sdk.service.jobs.{Format, JobEditMode}

Expand Down
3 changes: 2 additions & 1 deletion ...ph/intermediate/workflows/JobSource.scala → ...termediate/workflows/jobs/JobSource.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs
import com.databricks.sdk.service.jobs.JobSourceDirtyState

Expand Down
3 changes: 2 additions & 1 deletion ...termediate/workflows/JobsHealthRule.scala → ...diate/workflows/jobs/JobsHealthRule.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs
import com.databricks.sdk.service.jobs.{JobsHealthMetric, JobsHealthOperator}

Expand Down
3 changes: 2 additions & 1 deletion ...ermediate/workflows/JobsHealthRules.scala → ...iate/workflows/jobs/JobsHealthRules.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.jobs

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs

case class JobsHealthRules(rules: Seq[JobsHealthRule] = Seq.empty) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...ermediate/workflows/DockerBasicAuth.scala → ...workflows/libraries/DockerBasicAuth.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.libraries

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class DockerBasicAuth(password: Option[String], username: Option[String] = None) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion .../intermediate/workflows/DockerImage.scala → ...ate/workflows/libraries/DockerImage.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.libraries

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class DockerImage(basicAuth: Option[DockerBasicAuth], url: Option[String] = None) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion .../intermediate/workflows/Environment.scala → ...ate/workflows/libraries/Environment.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.libraries

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class Environment(client: String, dependencies: Seq[String] = Seq.empty) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...orph/intermediate/workflows/Library.scala → ...mediate/workflows/libraries/Library.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.libraries

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class Library(
Expand Down
3 changes: 2 additions & 1 deletion ...intermediate/workflows/MavenLibrary.scala → ...te/workflows/libraries/MavenLibrary.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.libraries

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class MavenLibrary(coordinates: String, exclusions: Seq[String] = Seq.empty, repo: Option[String] = None)
Expand Down
3 changes: 2 additions & 1 deletion ...mediate/workflows/PythonPyPiLibrary.scala → ...rkflows/libraries/PythonPyPiLibrary.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.libraries

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class PythonPyPiLibrary(spec: String, repo: Option[String] = None) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...intermediate/workflows/RCranLibrary.scala → ...te/workflows/libraries/RCranLibrary.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.libraries

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class RCranLibrary(spec: String, repo: Option[String] = None) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...h/intermediate/workflows/Continuous.scala → ...iate/workflows/schedules/Continuous.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.schedules

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs
import com.databricks.sdk.service.jobs.PauseStatus

Expand Down
3 changes: 2 additions & 1 deletion ...intermediate/workflows/CronSchedule.scala → ...te/workflows/schedules/CronSchedule.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.schedules

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs
import com.databricks.sdk.service.jobs.PauseStatus

Expand Down
3 changes: 2 additions & 1 deletion ...ows/FileArrivalTriggerConfiguration.scala → ...les/FileArrivalTriggerConfiguration.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.schedules

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs

case class FileArrivalTriggerConfiguration(
Expand Down
3 changes: 2 additions & 1 deletion ...kflows/PeriodicTriggerConfiguration.scala → ...edules/PeriodicTriggerConfiguration.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.schedules

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs
import com.databricks.sdk.service.jobs.PeriodicTriggerConfigurationTimeUnit

Expand Down
3 changes: 2 additions & 1 deletion ...ows/TableUpdateTriggerConfiguration.scala → ...les/TableUpdateTriggerConfiguration.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.schedules

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs
import com.databricks.sdk.service.jobs.Condition

Expand Down
3 changes: 2 additions & 1 deletion ...ermediate/workflows/TriggerSettings.scala → ...workflows/schedules/TriggerSettings.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.schedules

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs
import com.databricks.sdk.service.jobs.PauseStatus

Expand Down
3 changes: 2 additions & 1 deletion ...intermediate/workflows/Adlsgen2Info.scala → ...iate/workflows/sources/Adlsgen2Info.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.sources

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class Adlsgen2Info(destination: String) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...ermediate/workflows/DbfsStorageInfo.scala → ...e/workflows/sources/DbfsStorageInfo.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.sources

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class DbfsStorageInfo(destination: String) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...termediate/workflows/GcsStorageInfo.scala → ...te/workflows/sources/GcsStorageInfo.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.sources

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class GcsStorageInfo(destination: String) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion .../intermediate/workflows/GitSnapshot.scala → ...diate/workflows/sources/GitSnapshot.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.sources

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.jobs

case class GitSnapshot(usedCommit: Option[String] = None) extends JobNode {
Expand Down
4 changes: 3 additions & 1 deletion ...ph/intermediate/workflows/GitSource.scala → ...mediate/workflows/sources/GitSource.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.sources

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.labs.remorph.intermediate.workflows.jobs.JobSource
import com.databricks.sdk.service.jobs
import com.databricks.sdk.service.jobs.GitProvider

Expand Down
3 changes: 2 additions & 1 deletion ...ntermediate/workflows/LocalFileInfo.scala → ...ate/workflows/sources/LocalFileInfo.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.sources

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class LocalFileInfo(destination: String) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...ntermediate/workflows/S3StorageInfo.scala → ...ate/workflows/sources/S3StorageInfo.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.sources

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class S3StorageInfo(
Expand Down
3 changes: 2 additions & 1 deletion ...ediate/workflows/VolumesStorageInfo.scala → ...orkflows/sources/VolumesStorageInfo.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.sources

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class VolumesStorageInfo(destination: String) extends JobNode {
Expand Down
3 changes: 2 additions & 1 deletion ...iate/workflows/WorkspaceStorageInfo.scala → ...kflows/sources/WorkspaceStorageInfo.scala
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.databricks.labs.remorph.intermediate.workflows
package com.databricks.labs.remorph.intermediate.workflows.sources

import com.databricks.labs.remorph.intermediate.workflows.JobNode
import com.databricks.sdk.service.compute

case class WorkspaceStorageInfo(destination: String) extends JobNode {
Expand Down
Loading

0 comments on commit c82cd0c

Please sign in to comment.