Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Breadth Coverage] Stream Analytics #1386

Merged
merged 12 commits into from
Mar 17, 2020
Prev Previous commit
Next Next commit
fix wait command problem
  • Loading branch information
arrownj committed Mar 16, 2020
commit e82333743032e9b86fcfede17ab87b0691ef8f9b
9 changes: 9 additions & 0 deletions src/stream-analytics/azext_stream_analytics/_help.py
Original file line number Diff line number Diff line change
Expand Up @@ -95,6 +95,15 @@
az stream-analytics job stop --resource-group MyResourceGroup --name MyJobName
"""

helps['stream-analytics job wait'] = """
type: command
short-summary: Place the CLI in a waiting state until a condition of the streaming job is met.
examples:
- name: Pause executing next line of CLI script until the streaming job is successfully provisioned.
text: |
az stream-analytics job wait --resource-group MyResourceGroup --name MyJobName --created
"""

helps['stream-analytics input'] = """
type: group
short-summary: Commands to manage stream-analytics input.
Expand Down
3 changes: 3 additions & 0 deletions src/stream-analytics/azext_stream_analytics/_params.py
Original file line number Diff line number Diff line change
Expand Up @@ -74,6 +74,9 @@ def load_arguments(self, _):
with self.argument_context('stream-analytics job stop') as c:
c.argument('name', options_list=['--name', '-n'], help='The name of the streaming job.')

with self.argument_context('stream-analytics job wait') as c:
c.argument('job_name', options_list=['--name', '-n'], help='The name of the streaming job.')

with self.argument_context('stream-analytics input create') as c:
c.argument('job_name', id_part='name', help='The name of the streaming job.')
c.argument('name', id_part='child_name_1', options_list=['--name', '-n'], help='The name of the input.')
Expand Down
3 changes: 0 additions & 3 deletions src/stream-analytics/azext_stream_analytics/commands.py
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,6 @@ def load_command_table(self, _):
g.custom_show_command('show', 'get_stream_analytics_input')
g.custom_command('list', 'list_stream_analytics_input')
g.custom_command('test', 'test_stream_analytics_input', supports_no_wait=True)
g.wait_command('wait')

from ._client_factory import cf_outputs
stream_analytics_outputs = CliCommandType(
Expand All @@ -49,7 +48,6 @@ def load_command_table(self, _):
g.custom_show_command('show', 'get_stream_analytics_output')
g.custom_command('list', 'list_stream_analytics_output')
g.custom_command('test', 'test_stream_analytics_output', supports_no_wait=True)
g.wait_command('wait')

from ._client_factory import cf_transformations
stream_analytics_transformations = CliCommandType(
Expand All @@ -70,7 +68,6 @@ def load_command_table(self, _):
g.custom_show_command('show', 'get_stream_analytics_function')
g.custom_command('list', 'list_stream_analytics_function')
g.custom_command('test', 'test_stream_analytics_function', supports_no_wait=True)
g.wait_command('wait')

from ._client_factory import cf_subscriptions
stream_analytics_subscriptions = CliCommandType(
Expand Down