Skip to content

Instantly share code, notes, and snippets.

"""Test pipeline to exercise various data flow mechanisms."""
import kfp
"""Producer"""
def send_file(
outgoing_file: kfp.components.OutputPath(),
):
def create_test_file(path, size):
with open(path, 'wb') as file:
"""Test pipeline to exercise various data flow mechanisms."""
import kfp
"""Producer"""
def send_file(
outgoing_file: kfp.components.OutputPath(),
):
def create_test_file(path, size):
with open(path, 'wb') as file:
"""Test pipeline to exercise various data flow mechanisms."""
import kfp
"""Producer"""
def send_file(
outgoing_file: kfp.components.OutputPath(),
):
def create_test_file(path, size):
with open(path, 'wb') as file:
@gregsheremeta
gregsheremeta / dev-node.yaml
Created July 10, 2018 17:42
dev-node.yml
---
# tasks file for dev-base
# setup repos
- dnf:
name: fedora-workstation-repositories
state: latest
- name: enable yarn repo
/*
Copyright (c) 2018 Red Hat, Inc.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software