Skip to content
This repository has been archived by the owner on Oct 9, 2023. It is now read-only.

Commit

Permalink
fixed unit tests
Browse files Browse the repository at this point in the history 
Signed-off-by: Daniel Rammer <[email protected]>
  • Loading branch information
@hamersaw
hamersaw committed May 3, 2023
1 parent 2e17adc commit 57bfc0d
Show file tree
Hide file tree
Showing 44 changed files with 44 additions and 1 deletion.
1 change: 1 addition & 0 deletions ...est/testdata/snacks-core/k8s/002_core.containerization.multi_images.my_workflow_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...mpiler/test/testdata/snacks-core/k8s/010_core.containerization.raw_container.wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...stdata/snacks-core/k8s/015_core.containerization.use_secrets.my_secret_workflow_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions .../test/testdata/snacks-core/k8s/019_core.control_flow.chain_tasks.chain_tasks_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...compiler/test/testdata/snacks-core/k8s/022_core.control_flow.checkpoint.example_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...piler/test/testdata/snacks-core/k8s/026_core.control_flow.conditions.multiplier_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...ler/test/testdata/snacks-core/k8s/028_core.control_flow.conditions.multiplier_2_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...ler/test/testdata/snacks-core/k8s/030_core.control_flow.conditions.multiplier_3_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...test/testdata/snacks-core/k8s/035_core.control_flow.conditions.basic_boolean_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...er/test/testdata/snacks-core/k8s/037_core.control_flow.conditions.bool_input_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...est/testdata/snacks-core/k8s/039_core.control_flow.conditions.nested_conditions_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions .../test/testdata/snacks-core/k8s/042_core.control_flow.conditions.consume_outputs_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions pkg/compiler/test/testdata/snacks-core/k8s/048_core.control_flow.dynamics.wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...er/test/testdata/snacks-core/k8s/053_core.control_flow.map_task.my_map_workflow_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...piler/test/testdata/snacks-core/k8s/059_core.control_flow.merge_sort.merge_sort_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...piler/test/testdata/snacks-core/k8s/062_core.control_flow.subworkflows.my_subwf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...r/test/testdata/snacks-core/k8s/069_core.control_flow.subworkflows.ext_workflow_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...t/testdata/snacks-core/k8s/077_core.extend_flyte.custom_task_plugin.my_workflow_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions pkg/compiler/test/testdata/snacks-core/k8s/081_core.extend_flyte.custom_types.wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...mpiler/test/testdata/snacks-core/k8s/085_core.flyte_basics.basic_workflow.my_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...ompiler/test/testdata/snacks-core/k8s/089_core.flyte_basics.decorating_tasks.wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...ler/test/testdata/snacks-core/k8s/095_core.flyte_basics.decorating_workflows.wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...data/snacks-core/k8s/098_core.flyte_basics.documented_workflow.sphinx_docstring_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...tdata/snacks-core/k8s/100_core.flyte_basics.documented_workflow.numpy_docstring_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...data/snacks-core/k8s/102_core.flyte_basics.documented_workflow.google_docstring_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...er/test/testdata/snacks-core/k8s/105_core.flyte_basics.files.normalize_csv_file_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions .../snacks-core/k8s/109_core.flyte_basics.folders.download_and_normalize_csv_files_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions pkg/compiler/test/testdata/snacks-core/k8s/112_core.flyte_basics.hello_world.my_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions pkg/compiler/test/testdata/snacks-core/k8s/117_my.imperative.workflow.example_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions pkg/compiler/test/testdata/snacks-core/k8s/120_core.flyte_basics.lp.my_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions pkg/compiler/test/testdata/snacks-core/k8s/125_core.flyte_basics.lp.go_greet_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...ompiler/test/testdata/snacks-core/k8s/129_core.flyte_basics.named_outputs.my_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions pkg/compiler/test/testdata/snacks-core/k8s/140_core.flyte_basics.shell_task.wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...t/testdata/snacks-core/k8s/147_core.flyte_basics.task_cache.cached_dataframe_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...ata/snacks-core/k8s/151_core.scheduled_workflows.lp_schedules.date_formatter_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions .../testdata/snacks-core/k8s/155_core.scheduled_workflows.lp_schedules.positive_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions pkg/compiler/test/testdata/snacks-core/k8s/162_core.type_system.custom_objects.wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions pkg/compiler/test/testdata/snacks-core/k8s/166_core.type_system.enums.enum_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...ompiler/test/testdata/snacks-core/k8s/169_core.type_system.flyte_pickle.welcome_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions pkg/compiler/test/testdata/snacks-core/k8s/173_core.type_system.schema.df_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...snacks-core/k8s/179_core.type_system.structured_dataset.pandas_compatibility_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions ...snacks-core/k8s/181_core.type_system.structured_dataset.schema_compatibility_wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
1 change: 1 addition & 0 deletions pkg/compiler/test/testdata/snacks-core/k8s/185_core.type_system.typed_schema.wf_2_wf.yaml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
apiVersion: flyte.lyft.com/v1alpha1
executionConfig:
EnvironmentVariables: null
Interruptible: null
MaxParallelism: 0
OverwriteCache: false
Expand Down
2 changes: 1 addition & 1 deletion pkg/controller/nodes/dynamic/dynamic_workflow_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -498,7 +498,7 @@ func Test_dynamicNodeHandler_buildContextualDynamicWorkflow_withLaunchPlans(t *t
composedPBStore.OnWriteRawMatch(
mock.MatchedBy(func(ctx context.Context) bool { return true }),
storage.DataReference("s3://my-s3-bucket/foo/bar/futures_compiled.pb"),
int64(1473),
int64(1501),
storage.Options{},
mock.MatchedBy(func(rdr *bytes.Reader) bool { return true })).Return(errors.New("foo"))

Expand Down

0 comments on commit 57bfc0d

Please sign in to comment.