Skip to content

Commit

Permalink
lint
Browse files Browse the repository at this point in the history
  • Loading branch information
cameronraysmith committed May 17, 2023
1 parent a4e2923 commit b0a61a0
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 7 deletions.
2 changes: 1 addition & 1 deletion reproducibility/pipelines/argo/.gitignore
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
outputs/
multirun/
testing/
.envrc
.envrc
Original file line number Diff line number Diff line change
@@ -1,8 +1,9 @@
from kfp.v2 import dsl
from kfp.v2.dsl import Output, Dataset # , Input, Model, Artifact
from google_cloud_pipeline_components.v1.custom_job import (
create_custom_training_job_from_component,
)
from kfp.v2 import dsl
from kfp.v2.dsl import Dataset # , Input, Model, Artifact
from kfp.v2.dsl import Output


def create_environment_log_component(
Expand Down
3 changes: 2 additions & 1 deletion reproducibility/pipelines/argo/construct_pipeline.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
from kfp.v2 import dsl
from kfp.v2.dsl import Dataset # Output, Input, Model, Artifact


load_dotenv(".envrc")


Expand Down Expand Up @@ -34,5 +35,5 @@ def complete_pipeline(
location=location,
message=message,
).outputs["environment_info"]

return complete_pipeline
6 changes: 3 additions & 3 deletions reproducibility/pipelines/argo/run_pipeline.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@
from kfp.v2 import dsl
from kfp.v2.dsl import Dataset # Output, Input, Model, Artifact


load_dotenv(".envrc")


Expand All @@ -36,7 +37,6 @@

PipelineConf = builds(
create_complete_pipeline,

)
base_pipeline = PipelineConf(
pipeline_root=pipeline_root,
Expand All @@ -52,11 +52,11 @@
)
base_job = JobConf(
pipeline_func=base_pipeline,
parameter_values= {
parameter_values={
"project": os.environ["ARGO_GCP_PROJECT_ID"],
"location": os.environ["ARGO_GCP_REGION"],
"message": "message text",
}
},
)

job_store = store(group="job")
Expand Down

0 comments on commit b0a61a0

Please sign in to comment.