GitHub
01/06/2023, 6:05 PM$ kf get cm cluster-resource-templates -o yaml
apiVersion: v1
data:
ac_spark_role.yaml: |
apiVersion: <http://rbac.authorization.k8s.io/v1beta1|rbac.authorization.k8s.io/v1beta1>
kind: Role
metadata:
name: spark-role
namespace: {{ namespace }}
rules:
- apiGroups: ["*"]
resources: ["pods"]
verbs: ["*"]
- apiGroups: ["*"]
resources: ["services"]
verbs: ["*"]
- apiGroups: ["*"]
resources: ["configmaps", "persistentvolumeclaims"]
verbs: ["*"]
ad_spark_service_account.yaml: |
apiVersion: v1
kind: ServiceAccount
metadata:
name: spark
namespace: {{ namespace }}
ae_spark_role_binding.yaml: |
apiVersion: <http://rbac.authorization.k8s.io/v1beta1|rbac.authorization.k8s.io/v1beta1>
kind: RoleBinding
metadata:
name: spark-role-binding
namespace: {{ namespace }}
roleRef:
apiGroup: <http://rbac.authorization.k8s.io|rbac.authorization.k8s.io>
kind: Role
name: spark-role
subjects:
- kind: ServiceAccount
name: spark
namespace: {{ namespace }}
namespace.yaml: |
apiVersion: v1
kind: Namespace
metadata:
name: {{ namespace }}
kind: ConfigMap
Nits
• Logging level should be increased.
Misc
Are you sure this issue hasn't been raised already?
☑︎ Yes
Have you read the Code of Conduct?
☑︎ Yes
flyteorg/flyteGitHub
01/06/2023, 6:20 PMflyteidl
is available.GitHub
01/06/2023, 6:20 PM<https://github.com/flyteorg/flyteconsole/tree/master|master>
by jsonporter
<https://github.com/flyteorg/flyteconsole/commit/88bcfba9a96750884b524670652477c18f96c94d|88bcfba9>
- Overwriting of cached task outputs for a single execution #minor (#616)
flyteorg/flyteconsoleGitHub
01/06/2023, 6:38 PMflyte
binary should probably be built and released somewhere as well. Would be nice to be able to brew install
it.
Related to #2993
flyteorg/flyteGitHub
01/06/2023, 7:21 PMGitHub
01/06/2023, 7:22 PMGitHub
01/06/2023, 7:33 PM<https://github.com/flyteorg/flytesnacks/tree/master|master>
by cosmicBboy
<https://github.com/flyteorg/flytesnacks/commit/173aaa2c5986d2b015329720ab3cbc984b98369a|173aaa2c>
- Update lp_schedules.py (#936)
flyteorg/flytesnacksGitHub
01/06/2023, 7:54 PMGitHub
01/06/2023, 8:09 PMGitHub
01/06/2023, 9:21 PMGitHub
01/06/2023, 10:18 PMHugginface
and polars
transformer failed to read parquet file generated from other transformers, because those transformers always read the data from a specific path (.../00000), but we may have different file name in that folder.
We should read the data by default from a folder.
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
flyteorg/flyte#3189
Follow-up issue
NA
flyteorg/flytekitGitHub
01/06/2023, 10:50 PMGitHub
01/06/2023, 10:52 PM<https://github.com/flyteorg/flytekit/tree/master|master>
by cosmicBboy
<https://github.com/flyteorg/flytekit/commit/55b6602a7d4e3491d5175c6d9039369c2880fc98|55b6602a>
- Add support MLFlow plugin (#1274)
flyteorg/flytekitGitHub
01/06/2023, 10:52 PMfrom flytekit import task, workflow
from flytekitplugins.mlflow import mlflow_autolog
import mlflow
import tensorflow as tf
@task(disable_deck=False)
@mlflow_autolog(framework=mlflow.keras)
def train_model(epochs: int):
# Refer to <https://www.tensorflow.org/tutorials/keras/classification>
fashion_mnist = tf.keras.datasets.fashion_mnist
(train_images, train_labels), (_, _) = fashion_mnist.load_data()
train_images = train_images / 255.0
model = tf.keras.Sequential([
tf.keras.layers.Flatten(input_shape=(28, 28)),
tf.keras.layers.Dense(128, activation='relu'),
tf.keras.layers.Dense(10)
])
model.compile(optimizer='adam',
loss=tf.keras.losses.SparseCategoricalCrossentropy(from_logits=True),
metrics=['accuracy'])
model.fit(train_images, train_labels, epochs=epochs)
@workflow
def ml_pipeline(epochs: int):
train_model(epochs=epochs)
if __name__ == "__main__":
ml_pipeline()
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
image▾
image▾
image▾
image▾
image▾
image▾
GitHub
01/06/2023, 11:34 PMGitHub
01/07/2023, 12:04 AM<https://github.com/flyteorg/flytepropeller/tree/master|master>
by hamersaw
<https://github.com/flyteorg/flytepropeller/commit/d2098fc5d3a7fa7a94a3332560b27c36f0456126|d2098fc5>
- Add dask plugin (#508)
flyteorg/flytepropellerGitHub
01/07/2023, 12:25 AM@dynamic
decorator) will expand out the dynamically created tasks in the web UI after they are run, and will be displayed even after completion:
Screen Shot 2022-12-02 at 1 18 01 PM▾
Screen Shot 2022-12-14 at 8 11 08 PM▾
@dynamic
def train_workflow_inner(
recipe_path: str,
k_folds: int = 1,
) -> int:
data_flytedir = data_prep_task(recipe_path=recipe_path, recipe_hash=recipe_hash)
s = None
for i in range(k_folds):
model_and_data_flytedir = training_task(
data=data_flytedir,
k_folds=k_folds,
i_fold=i,
)
s = eval_task(data=model_and_data_flytedir)
return s
flyteorg/flyteGitHub
01/07/2023, 12:57 AMGitHub
01/07/2023, 5:22 AMGitHub
01/07/2023, 5:27 AM<https://github.com/flyteorg/flyte/tree/master|master>
by jeevb
<https://github.com/flyteorg/flyte/commit/0d9aa541afbf6c63a56e1a922bf2e14c078f8637|0d9aa541>
- Build flyte-binary image during sandbox-bundled build (#3216)
flyteorg/flyteGitHub
01/07/2023, 5:40 AMGitHub
01/07/2023, 5:51 AMGitHub
01/07/2023, 6:44 AMGitHub
01/07/2023, 4:01 PM<https://github.com/flyteorg/flytekit/tree/master|master>
by cosmicBboy
<https://github.com/flyteorg/flytekit/commit/fcf6dcefe36220c244b03f76c16dfdd772d6379b|fcf6dcef>
- fix remote API reference (#1405)
flyteorg/flytekitGitHub
01/09/2023, 3:59 AM<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-backupGitHub
01/09/2023, 7:40 AMGitHub
01/09/2023, 7:55 AM<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-javaGitHub
01/09/2023, 7:56 AM<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-javaGitHub
01/09/2023, 10:04 AMGitHub
01/09/2023, 12:13 PM