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.

Sign up for GitHub

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

Jump to bottom

Agent Get Pending Message #1834

Merged
merged 30 commits into from
Nov 21, 2023
Merged

Agent Get Pending Message #1834

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
30 commits
Select commit Hold shift + click to select a range
540eb5d
Merge branch 'master' of https://github.com/Future-Outlier/flytekit
Aug 12, 2023
984d44a
Merge branch 'master' of https://github.com/Future-Outlier/flytekit
Aug 16, 2023
3d936fc
Merge branch 'master' of https://github.com/Future-Outlier/flytekit
Aug 30, 2023
931533a
Merge branch 'master' of https://github.com/Future-Outlier/flytekit
Sep 7, 2023
bd5dbd7
Merge branch 'master' of https://github.com/Future-Outlier/flytekit
Sep 13, 2023
aeb5ea1
Merge branch 'master' of https://github.com/Future-Outlier/flytekit
Sep 13, 2023
9d7db22
Agent Service Get Message
Sep 14, 2023
fc0a5a3
format string
Sep 14, 2023
54d2ddf
Merge branch 'flyteorg:master' into master
Future-Outlier Sep 17, 2023
541edc6
Merge branch 'flyteorg:master' into master
Future-Outlier Sep 19, 2023
75573ab
Merge branch 'flyteorg:master' into master
Future-Outlier Sep 23, 2023
c0139db
Merge pull request #19 from flyteorg/master
Future-Outlier Sep 28, 2023
24df7b3
Merge branch 'flyteorg:master' into master
Future-Outlier Oct 3, 2023
563ca22
Merge branch 'flyteorg:master' into master
Future-Outlier Oct 4, 2023
5fa4f18
Merge branch 'flyteorg:master' into master
Future-Outlier Oct 6, 2023
5f1183b
Merge branch 'flyteorg:master' into master
Future-Outlier Oct 6, 2023
203d2d4
Merge branch 'flyteorg:master' into master
Future-Outlier Oct 7, 2023
79d315c
Merge branch 'master' of https://github.com/Future-Outlier/flytekit i…
Oct 7, 2023
27b598a
Merge branch 'master' of https://github.com/Future-Outlier/flytekit i…
Nov 5, 2023
5a42415
nit
Nov 5, 2023
424f500
update flyteidl version
Nov 5, 2023
2f8c0cc
update requirements
Nov 6, 2023
9b8a1f6
dependency
Nov 6, 2023
31b4f0d
update py38 dependencies
Nov 6, 2023
539bad1
Update plugins/flytekit-spark/flytekitplugins/spark/agent.py
Future-Outlier Nov 7, 2023
122c802
lint
Nov 7, 2023
5b93c6b
Merge branch 'master' of https://github.com/Future-Outlier/flytekit i…
Nov 15, 2023
65faacd
Merge branch 'master' of https://github.com/Future-Outlier/flytekit i…
Nov 21, 2023
035ae1e
papermil dev-req
Nov 21, 2023
fcaa2a3
update numpy
pingsutw Nov 21, 2023
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
2 changes: 1 addition & 1 deletion flytekit/extend/backend/base_agent.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -215,7 +215,7 @@ async def _get(self, resource_meta: bytes) -> GetTaskResponse:
else:
res = self._agent.get(grpc_ctx, resource_meta)
state = res.resource.state
logger.info(f"Task state: {state}")
logger.info(f"Task state: {state}, State message: {res.resource.message}")
return res

def signal_handler(self, resource_meta: bytes, signum: int, frame: FrameType) -> typing.Any:
Expand Down
2 changes: 1 addition & 1 deletion plugins/flytekit-papermill/dev-requirements.in
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
flyteidl>=1.3.0
flyteidl>=1.10.0
-e file:../../.#egg=flytekitplugins-pod&subdirectory=plugins/flytekit-k8s-pod
-e file:../../.#egg=flytekitplugins-spark&subdirectory=plugins/flytekit-spark
-e file:../../.#egg=flytekitplugins-awsbatch&subdirectory=plugins/flytekit-aws-batch
Loading