Skip to content

Commit

Permalink
Register DataBricksDeltaLakeSourceStage with the CLI (#1384)
Browse files Browse the repository at this point in the history
Closes #1383 

## By Submitting this PR I confirm:
- I am familiar with the [Contributing Guidelines](https://github.com/nv-morpheus/Morpheus/blob/main/docs/source/developer_guide/contributing.md).
- When the PR is ready for review, new or existing tests cover these changes.
- When the PR is ready for review, the documentation is up to date with these changes.

Authors:
  - David Gardner (https://github.com/dagardner-nv)

Approvers:
  - Michael Demoret (https://github.com/mdemoret-nv)

URL: #1384
  • Loading branch information
dagardner-nv authored Nov 22, 2023
1 parent d5665ba commit bc4d40d
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions morpheus/cli/commands.py
Original file line number Diff line number Diff line change
Expand Up @@ -654,6 +654,9 @@ def post_pipeline(ctx: click.Context, *args, **kwargs):
add_command("from-appshield", "morpheus.stages.input.appshield_source_stage.AppShieldSourceStage", modes=FIL_ONLY)
add_command("from-azure", "morpheus.stages.input.azure_source_stage.AzureSourceStage", modes=AE_ONLY)
add_command("from-cloudtrail", "morpheus.stages.input.cloud_trail_source_stage.CloudTrailSourceStage", modes=AE_ONLY)
add_command("from-databricks-deltalake",
"morpheus.stages.input.databricks_deltalake_source_stage.DataBricksDeltaLakeSourceStage",
modes=ALL)
add_command("from-duo", "morpheus.stages.input.duo_source_stage.DuoSourceStage", modes=AE_ONLY)
add_command("from-file", "morpheus.stages.input.file_source_stage.FileSourceStage", modes=NOT_AE)
add_command("from-kafka", "morpheus.stages.input.kafka_source_stage.KafkaSourceStage", modes=NOT_AE)
Expand Down

0 comments on commit bc4d40d

Please sign in to comment.