#3217 Test functional test Pull request opened by jeevb on <!date^1673070644^{date_short}|2023-01-07T05:50:44Z> flyteorg/flyte GitHub Actions: one GitHub Actions: one GitHub Actions: one GitHub Actions: one GitHub Actions: one GitHub Actions: one GitHub Actions: one GitHub Actions: one GitHub Actions: one GitHub Actions: one GitHub Actions: trigger-sandbox-lite-build ✅ 18 other checks have passed 18/29 successful checks

#508 Publish multi-architecture image Pull request opened by jeevb on <!date^1673073142^{date_short}|2023-01-07T06:32:22Z> Depends on: flyteorg/flytetools#70 flyteorg/flyteadmin GitHub Actions: Build & Push Flyteadmin Image GitHub Actions: Goreleaser GitHub Actions: Build & Push Flytescheduler Image GitHub Actions: Bump Version GitHub Actions: End2End Test GitHub Actions: Integration Test GitHub Actions: Docker Build Images / Build Docker Image ✅ 7 other checks have passed 7/14 successful checks

1 new commit pushed to

<https://github.com/flyteorg/flytekit/tree/master|master>

by cosmicBboy

<https://github.com/flyteorg/flytekit/commit/fcf6dcefe36220c244b03f76c16dfdd772d6379b|fcf6dcef>

- fix remote API reference (#1405) flyteorg/flytekit

1 new commit pushed to

<https://github.com/flyteorg/blog-posts-backup/tree/main|main>

by samhita-alla

<https://github.com/flyteorg/blog-posts-backup/commit/7c468a12a6d617221c965ffbc10dfcc1bf57493e|7c468a12>

- create post: The Three Virtues of MLOps: Velocity, Validation and Versioning flyteorg/blog-posts-backup

#3090 [Housekeeping] flyte.org, image incubation project =&gt; gratuated project Issue created by andife on <!date^1668888880^{date_short}|2022-11-19T20:14:40Z> Describe the issue Flyte seems to be a "gratuated project" at lfaidata. The landing page flyte.org still has an image with incubation project. What if we do not do this? webpage might be a bit longer outdated Related component(s) No response Are you sure this issue hasn't been raised already? ☑︎ Yes Have you read the Code of Conduct? ☑︎ Yes flyteorg/flyte

1 new commit pushed to

<https://github.com/flyteorg/flytekit-java/tree/master|master>

by github-actions[bot]

<https://github.com/flyteorg/flytekit-java/commit/c6bbe6ed0bd051028c24d5e7a8f724adab6197f1|c6bbe6ed>

- [maven-release-plugin] prepare release 0.3.28 flyteorg/flytekit-java

1 new commit pushed to

<https://github.com/flyteorg/flytekit-java/tree/master|master>

by github-actions[bot]

<https://github.com/flyteorg/flytekit-java/commit/674f07999b6c9a6f46dce535b299b500457eab50|674f0799>

- [maven-release-plugin] prepare for next development iteration flyteorg/flytekit-java

#163 Update maven central URL Pull request opened by honnix TL;DR Update maven central URL. This one refreshes faster. 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 Tracking Issue NA Follow-up issue NA flyteorg/flytekit-java

Release - 0.3.28 New release published by honnix • Auto generate node ID #162 flyteorg/flytekit-java

#937 Improve pod example Pull request opened by samhita-alla Signed-off-by: Samhita Alla aallasamhita@gmail.com This PR improves the existing pod documentation and adds a node selector example. flyteorg/flytesnacks ✅ All checks have passed 2/2 successful checks

#3218 [BUG] Misleading/erroneous `Caching was disabled for this execution.` for tasks with cache enabled Issue created by fg91 Describe the bug When a Python task - which has the cache enabled - fails, the flyte console displays an erroneous and misleading warning that

Caching was disabled for this execution.

I have also seen this warning for *_successful_ tasks (see screenshot) even though I unfortunately cannot come up with a minimal example to consistently reproduce this. Expected behavior This warning should not be shown. Additional context to reproduce

from flytekit import task, workflow


@task(
    cache=True,
    cache_version="1.0",
)
def fail() -> None:
    raise Exception()

@workflow
def workflow():
    fail()

Screenshots Erroneous warning for a successful task with _cache enabled_: I downloaded the tarball containing the code in order to make sure that for the respective version the cache is in fact enabled: Are you sure this issue hasn't been raised already? ☑︎ Yes Have you read the Code of Conduct? ☑︎ Yes flyteorg/flyte

1 new commit pushed to

<https://github.com/flyteorg/flyteconsole/tree/master|master>

by jsonporter

<https://github.com/flyteorg/flyteconsole/commit/cdafa9fcce52fd2a2ee3aa6b11b7e761ae62aa7b|cdafa9fc>

- chore(deps): bump minimatch from 3.0.4 to 3.1.2 (#659) flyteorg/flyteconsole

1 new commit pushed to

<https://github.com/flyteorg/flyteconsole/tree/master|master>

by jsonporter

<https://github.com/flyteorg/flyteconsole/commit/a9e1716f9906fd8530ce9b57dd02a0a42d9c93c1|a9e1716f>

- chore(deps): bump json5 from 1.0.1 to 1.0.2 (#658) flyteorg/flyteconsole

Pending review on flyteorg/flyte - Manage reminder [#1329] Update contributors' section (samhita-alla) a year stale · a year old · Waiting on _ @Ketan (kumare3)_ [#1408] Remove placeholders in secrets (jeevb) a year stale · a year old · Waiting on _ @Haytham Abuelfutuh_ [#2986] Automatic unassign for stale issues (Azanul) 2 months stale · 3 months old · Waiting on _ samhita-alla_ [#3213] Add conditional around the admin secrets (wild-endeavor) 3 days stale · 3 days old · Waiting on _ MorpheusXAUT, andrewwdye, hamersaw_

Pending review on flyteorg/flytekit-java - Manage reminder [#6] Update .env.local in README (kanterov) 9 months stale · 3 years old · Waiting on _ @Ketan (kumare3)_

#938 Document IgnoreOutputs exception Pull request opened by fg91 When trying to control which of the distributed workers of a PyTorch task returns its values to the subsequent tasks in the workflow (in the case that they are not the same), I couldn't find the information in the documentation and asked on Slack. In this PR I document the solution I was guided to on Slack in the mnist examples of distributed pytorch, tf, and mpi as this is where I first looked for an answer. It gives me a bit of sadness to propose to reproduce the same sentence three times, however, I cannot find one overarching documentation page for distributed training and as a user of the respective frameworks, this is where I would first look. Do you have a better proposition for where to document this? flyteorg/flytesnacks

#663 Publish multi-architecture image Pull request opened by jeevb on <!date^1673070063^{date_short}|2023-01-07T05:41:03Z> Depends on: flyteorg/flytetools#70 flyteorg/flyteconsole ✅ All checks have passed 2/2 successful checks

#939 Add databricks to index.rst Pull request opened by pingsutw Signed-off-by: Kevin Su pingsutw@gmail.com Add databricks to

index.rst

,

conf.py

, and

integration.rst

flyteorg/flytesnacks ✅ All checks have passed 3/3 successful checks

#514 Publish multi-architecture image Pull request opened by jeevb Depends on: flyteorg/flytetools#70 flyteorg/flytepropeller

#1313 Fix mypy errors Pull request opened by pingsutw TL;DR Fixed all the mypy errors 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 ^^^ Tracking Issue Fixes flyteorg/flyte#1030 Follow-up issue NA flyteorg/flytekit Codecov: 54.54% of diff hit (target 69.22%) ✅ 29 other checks have passed 29/30 successful checks

#3219 [Core feature] Default parquet-to-pandas encoder/decoder should support iterable read. Issue created by cosmicBboy Motivation: Why do you think this is important? The purpose of this issue is to support the use case where I can load `StructuredDataset`s iteratively as in:

structured_dataset.open(pd.Dataframe).iter()

Goal: What should the final outcome look like, ideally? The end user should be able to specify the partition column when they output a structured dataset:

@task
def make_df() -> StructuredDataset:
    df = pd.DataFrame.from_records([
        {
            "id": i,
            "partition": (i % 10) + 1,
            "name": "".join(
                random.choices(string.ascii_uppercase + string.digits, k=10)
            )
        }
        for i in range(1000)
    ])
    return StructuredDataset(dataframe=df, partition_cols=["partition"])  # or ["partition1", "partition2"]

And then consume it like so:

@task
def use_df(dataset: StructuredDataset) -> pd.DataFrame:
    output = []
    for dd in dataset.open(pd.DataFrame).iter():
        print(f"This is a partial dataframe")
        print(dd.head(3))
        output.append(dd)
    return pd.concat(output)

Describe alternatives you've considered The user needs to implement their own encoder/decoder for this use case. Propose: Link/Inline OR Additional context There is a working implementation of this here: https://github.com/flyteorg/flyte-demos/blob/main/flyte_demo/workflows/data_iter.py#L101 Are you sure this issue hasn't been raised already? ☑︎ Yes Have you read the Code of Conduct? ☑︎ Yes flyteorg/flyte

#940 Fix walkthrough command for pima diabetes classification example Pull request opened by kanyesthaker The current "Walkthrough" command for the Diabetes Classification example has its arguments in an incorrect order, which causes the command to fail with error

Error: No such option: --image

. This PR puts the arguments in the correct order. Signed-off-by: Kanyes Thaker kanyes.thaker@gmail.com flyteorg/flytesnacks

#3220 [Core feature] Kafka Authentication Issue created by pingsutw Motivation: Why do you think this is important? In flyteadmin, we send a cloud event to Kafka. However, we don't have any authentication for Kafka right now. we should expose auth config, use

Sarama

api to read the config, and send the request to Kafka. Goal: What should the final outcome look like, ideally? CloudEvent Config

cloudevents:
    enable: true
    kafka:
      brokers: <kafka_ip>
      version:  1.2.1
      security_ protocol: SASL_SSL
      sasl_config: <config for SASL>

Describe alternatives you've considered NA Propose: Link/Inline OR Additional context Slack Thread: • https://flyte-org.slack.com/archives/CP2HDHKE1/p1667307468058299 • https://flyte-org.slack.com/archives/CP2HDHKE1/p1667412056307629 • https://flyte-org.slack.com/archives/CP2HDHKE1/p1670577684352189 • https://flyte-org.slack.com/archives/CP2HDHKE1/p1667412056307629 Authentication Methods Overview Are you sure this issue hasn't been raised already? ☑︎ Yes Have you read the Code of Conduct? ☑︎ Yes flyteorg/flyte

#70 Publish multi-architecture images Pull request opened by jeevb on <!date^1673051136^{date_short}|2023-01-07T00:25:36Z> Addresses: flyteorg/flyte#2935 flyteorg/flytetools ✅ All checks have passed 2/2 successful checks

1 new commit pushed to

<https://github.com/flyteorg/flytetools/tree/master|master>

by wild-endeavor

<https://github.com/flyteorg/flytetools/commit/27211db21d30b8526e4dc06948bc5550efca4ec5|27211db2>

- Publish multi-architecture images (#70) flyteorg/flytetools

1 new commit pushed to

<https://github.com/flyteorg/flyteconsole/tree/master|master>

by jeevb

<https://github.com/flyteorg/flyteconsole/commit/567afbe19783949eab9a46a90668c47ede654893|567afbe1>

- Publish multi-architecture image (#663) flyteorg/flyteconsole

#664 Fix dependency of release pipeline Pull request opened by jeevb Read then delete this section - Make sure to use a concise title for the pull-request. _- Use #patch, #minor or #major in the pull-request title to bump the corresponding version. Otherwise, the patch version will be bumped. More details_ TL;DR Please replace this text with a description of what this PR accomplishes. 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 How did you fix the bug, make the feature etc. Link to any design docs etc Tracking Issue _Remove the '_fixes_' keyword if there will be multiple PRs to fix the linked issue_ fixes https://github.com/flyteorg/flyte/issues/ Follow-up issue NA OR https://github.com/flyteorg/flyte/issues/ flyteorg/flyteconsole

1 new commit pushed to

<https://github.com/flyteorg/flyteconsole/tree/master|master>

by jeevb

<https://github.com/flyteorg/flyteconsole/commit/516bbffd1e808d5b93f097ed962a26330f96b71f|516bbffd>

- fix: Dependency of release pipeline (#664) flyteorg/flyteconsole

#88 Publish multi-architecture image Pull request opened by jeevb Depends on: flyteorg/flytetools#70 flyteorg/datacatalog Codecov: 68.41% (-1.14%) compared to 8a0429f GitHub Actions: Goreleaser GitHub Actions: Build & Push Datacatalog Image GitHub Actions: Bump Version ✅ 7 other checks have passed 7/11 successful checks