GitHub
03/17/2023, 3:01 PM<https://github.com/flyteorg/flytekit-java/tree/master|master>
by github-actions[bot]
<https://github.com/flyteorg/flytekit-java/commit/abe896bccc72df421c66314eef98d82cf39c376b|abe896bc>
- [maven-release-plugin] prepare release 0.4.11
flyteorg/flytekit-javaGitHub
03/17/2023, 3:01 PM<https://github.com/flyteorg/flytekit-java/tree/master|master>
by github-actions[bot]
<https://github.com/flyteorg/flytekit-java/commit/7212239dfd14680bdb33d3dcb83cc1141d3eb158|7212239d>
- [maven-release-plugin] prepare for next development iteration
flyteorg/flytekit-javaGitHub
03/17/2023, 5:02 PMGitHub
03/17/2023, 5:14 PM<https://github.com/flyteorg/flyteconsole/tree/master|master>
by ursucarina
<https://github.com/flyteorg/flyteconsole/commit/b3074dc636d20d5682a7f9629830bebb6e91c279|b3074dc6>
- fix: release fail (#726)
flyteorg/flyteconsoleGitHub
03/17/2023, 5:29 PM<https://github.com/flyteorg/flytekit-java/tree/master|master>
by github-actions[bot]
<https://github.com/flyteorg/flytekit-java/commit/99d14bff71d028381c6fcf62ce424b46ca0c7915|99d14bff>
- [maven-release-plugin] prepare release 0.4.12
flyteorg/flytekit-javaGitHub
03/17/2023, 5:29 PM<https://github.com/flyteorg/flytekit-java/tree/master|master>
by github-actions[bot]
<https://github.com/flyteorg/flytekit-java/commit/ae39aafc77c3e81a3ddfaeb74d8d8512da260aed|ae39aafc>
- [maven-release-plugin] prepare for next development iteration
flyteorg/flytekit-javaGitHub
03/17/2023, 5:30 PMGitHub
03/17/2023, 5:44 PMGitHub
03/17/2023, 6:31 PMGitHub
03/17/2023, 6:36 PMGitHub
03/17/2023, 6:36 PMGitHub
03/17/2023, 6:50 PM<https://github.com/flyteorg/flyte/tree/master|master>
by wild-endeavor
<https://github.com/flyteorg/flyte/commit/b6b0da712d138cb887cc107429fa42846ed9b8d9|b6b0da71>
- Revert "starting controller runtime manager (#3471)" (#3489)
flyteorg/flyteGitHub
03/17/2023, 7:37 PM<https://github.com/flyteorg/flyte/tree/master|master>
by wild-endeavor
<https://github.com/flyteorg/flyte/commit/9bef5ffc16f5aafc4ff07a64bce86d0b55dddd8a|9bef5ffc>
- [v1.4.2] Update Flyte components (#3487)
flyteorg/flyteGitHub
03/17/2023, 7:38 PMGitHub
03/17/2023, 7:39 PMGitHub
03/17/2023, 7:56 PMGitHub
03/17/2023, 7:57 PMGitHub
03/17/2023, 8:01 PMGitHub
03/17/2023, 8:06 PM<https://github.com/flyteorg/flytesnacks/tree/master|master>
by eapolinario
<https://github.com/flyteorg/flytesnacks/commit/81b71ec26344d3e6c9e63c98c90020f9c6e62b07|81b71ec2>
- Comment out schema_compatibility_df workflow temporarily (#973)
flyteorg/flytesnacksGitHub
03/17/2023, 9:06 PMGitHub
03/17/2023, 9:08 PMfrom flytekit import workflow, task
class MyClass:
@task
def t1(self):
return 'hello world'
@workflow
def wf():
MyClass().t1()
there will be lots of work for us as we need to convert all the classes to functions so that these functions can be decorated as tasks. I believe this feature is important for the following reasons:
• Encourage people to build more Flyte pipelines for the existing projects
• The code will be more organized and concise
Goal: What should the final outcome look like, ideally?
In the end, I hope Flyte can support something like the following
from flytekit import workflow, task
class MyClass:
@task
def t1(self):
return 'hello world'
@workflow
def wf():
MyClass().t1()
That is to define tasks within classes
Describe alternatives you've considered
I don't think I have any alternative for this issue.
Propose: Link/Inline OR Additional context
No response
Are you sure this issue hasn't been raised already?
☑︎ Yes
Have you read the Code of Conduct?
☑︎ Yes
flyteorg/flyteGitHub
03/17/2023, 9:35 PM<https://github.com/flyteorg/flyteadmin/tree/master|master>
by eapolinario
<https://github.com/flyteorg/flyteadmin/commit/8cf8b4aba63cda8426da806e689534e1d374bd1b|8cf8b4ab>
- Upgrade flytepropeller (#541)
flyteorg/flyteadminGitHub
03/17/2023, 10:16 PMGitHub
03/17/2023, 10:57 PMGitHub
03/17/2023, 11:11 PMGitHub
03/17/2023, 11:29 PMGitHub
03/18/2023, 12:44 AMimageSpec
, user can specify it in the either @task
or @workflow
, then flytekit will build the image at registration time.
Type
☐ Bug Fix
☑︎ Feature
☑︎ Plugin
Are all requirements met?
☐ Code completed
☐ Smoke tested
☐ Unit tests added
☐ Code documentation added
☐ Any pending items have an associated Issue
Complete description
Example:
from flytekit import task, workflow
from flytekit.image_spec.image_spec import ImageSpec
@task
def t2() -> str:
print("hello")
return "hello"
@task(image_spec=ImageSpec(packages=["pandas", "numpy"], registry="pingsutw"))
def t1() -> str:
print("hello")
print("hello")
return "hello"
@workflow(image_spec=ImageSpec(
packages=["git+<https://github.com/flyteorg/flytekit@4834ba03470b66f2f7c800c6b08e77062f2442b6%22|https://github.com/flyteorg/flytekit@4834ba03470b66f2f7c800c6b08e77062f2442b6">],
apt_packages=["git"],
registry="pingsutw")
)
def wf():
t1()
t2()
if __name__ == '__main__':
wf()
image▾
image▾
{
"pingsutw": [
"9zGai7ij01MWkewVim1cxg..",
"2mvWPRSd8LMbtyhyanIO5Q..",
"48b32eb8bbd164cbcf021f4c944c3aed",
"b91e0d14186edfef00d7ffafd642ffa2",
"dba9147b996c9d40a8a612fb34dc5ce7",
"850d8a35b44ba2694019256e560d2770",
"dff95b42bf5c3273942dd8cf2f7dbbaa",
"613633db1f727f3645621a5b7b9e9b9f",
"05db5f898e1a5ccdc2796ebea33a4454"
]
}
Tracking Issue
https://github.com/flyteorg/flyte/issues/
Follow-up issue
TODO:
1. Docs
2. pyflyte build --remote
flyteorg/flytekit
✅ All checks have passed
30/30 successful checksGitHub
03/20/2023, 4:53 AM@task(container_image="")
def foo():
import my_module1
<http://my_module1.xyz|my_module1.xyz>()
...
@task(container_image="")
def foo2():
import my_module2
my_module2.abc():
...
We need to add an example that imports libraries within tasks. This is helpful when tasks import different dependencies.
Are you sure this issue hasn't been raised already?
☑︎ Yes
Have you read the Code of Conduct?
☑︎ Yes
flyteorg/flyteGitHub
03/20/2023, 8:04 AMUnit
when checking "null" inputs by @narape in #206
• Fix dynamic workflows serialization by @narape in #212
• [Snyk] Upgrade com.google.api.grpc:proto-google-common-protos from 2.14.0 to 2.14.1 by @snyk-bot in #207
• Add registerLaunchPlan with action to SimpleSdkLaunchPlanRegistry by @pablocasares in #211
Full Changelog: 0.4.6...0.4.7
flyteorg/flytekit-javaGitHub
03/20/2023, 3:12 PM