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

Add get and list matchable attribute to flyte-cli #157

Merged
merged 5 commits into from
Aug 17, 2020
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
merge conflicts
katrogan committed Aug 14, 2020

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
commit fa217b451d4491e25701db04d5aa4d335e5d1562
19 changes: 12 additions & 7 deletions flytekit/clients/friendly.py
Original file line number Diff line number Diff line change
@@ -2,12 +2,17 @@

import six as _six

from flyteidl.admin import task_pb2 as _task_pb2, common_pb2 as _common_pb2, workflow_pb2 as _workflow_pb2, \
launch_plan_pb2 as _launch_plan_pb2, execution_pb2 as _execution_pb2, node_execution_pb2 as _node_execution_pb2, \
task_execution_pb2 as _task_execution_pb2, project_pb2 as _project_pb2, project_domain_attributes_pb2 as \
_project_domain_attributes_pb2, workflow_attributes_pb2 as _workflow_attributes_pb2, matchable_resource_pb2 as \
_matchable_resource_pb2
from flyteidl.core import identifier_pb2 as _identifier_pb2
from flyteidl.admin import common_pb2 as _common_pb2
from flyteidl.admin import execution_pb2 as _execution_pb2
from flyteidl.admin import launch_plan_pb2 as _launch_plan_pb2
from flyteidl.admin import matchable_resource_pb2 as _matchable_resource_pb2
from flyteidl.admin import node_execution_pb2 as _node_execution_pb2
from flyteidl.admin import project_domain_attributes_pb2 as _project_domain_attributes_pb2
from flyteidl.admin import project_pb2 as _project_pb2
from flyteidl.admin import task_execution_pb2 as _task_execution_pb2
from flyteidl.admin import task_pb2 as _task_pb2
from flyteidl.admin import workflow_attributes_pb2 as _workflow_attributes_pb2
from flyteidl.admin import workflow_pb2 as _workflow_pb2

from flytekit.clients.raw import RawSynchronousFlyteClient as _RawSynchronousFlyteClient
from flytekit.models import common as _common
@@ -872,4 +877,4 @@ def list_matchable_attributes(self, resource_type):
_matchable_resource_pb2.ListMatchableAttributesRequest(
resource_type=resource_type,
)
)
)
2 changes: 2 additions & 0 deletions flytekit/clients/helpers.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@


def iterate_node_executions(
client, workflow_execution_identifier=None, task_execution_identifier=None, limit=None, filters=None,
):
16 changes: 10 additions & 6 deletions flytekit/clis/flyte_cli/main.py
Original file line number Diff line number Diff line change
@@ -36,11 +36,15 @@
from flytekit.models import literals as _literals
from flytekit.models import named_entity as _named_entity
from flytekit.models.admin import common as _admin_common
from flytekit.models.core import execution as _core_execution_models, identifier as _core_identifier
from flytekit.models.execution import ExecutionSpec as _ExecutionSpec, ExecutionMetadata as _ExecutionMetadata
from flytekit.models.matchable_resource import ClusterResourceAttributes as _ClusterResourceAttributes,\
ExecutionQueueAttributes as _ExecutionQueueAttributes, ExecutionClusterLabel as _ExecutionClusterLabel,\
MatchingAttributes as _MatchingAttributes, MatchableResource as _MatchableResource
from flytekit.models.core import execution as _core_execution_models
from flytekit.models.core import identifier as _core_identifier
from flytekit.models.execution import ExecutionMetadata as _ExecutionMetadata
from flytekit.models.execution import ExecutionSpec as _ExecutionSpec
from flytekit.models.matchable_resource import ClusterResourceAttributes as _ClusterResourceAttributes
from flytekit.models.matchable_resource import ExecutionClusterLabel as _ExecutionClusterLabel
from flytekit.models.matchable_resource import ExecutionQueueAttributes as _ExecutionQueueAttributes
from flytekit.models.matchable_resource import MatchableResource as _MatchableResource
from flytekit.models.matchable_resource import MatchingAttributes as _MatchingAttributes
from flytekit.models.project import Project as _Project
from flytekit.models.schedule import Schedule as _Schedule

@@ -1792,7 +1796,7 @@ def list_matching_attributes(host, insecure, resource_type):
_click.echo("{}".format(configuration.attributes))


@_flyte_cli.command('setup-config', cls=_click.Command)
@_flyte_cli.command("setup-config", cls=_click.Command)
@_host_option
@_insecure_option
def setup_config(host, insecure):
You are viewing a condensed version of this merge commit. You can view the full changes here.