upload files/directories when using remote-workflow (#2222)

* enable remote Signed-off-by: Samhita Alla <[email protected]> * modify flyte context Signed-off-by: Samhita Alla <[email protected]> * remove dict update Signed-off-by: Samhita Alla <[email protected]> * revert format Signed-off-by: Samhita Alla <[email protected]> * revert format Signed-off-by: Samhita Alla <[email protected]> --------- Signed-off-by: Samhita Alla <[email protected]> Co-authored-by: Kevin Su <[email protected]> Signed-off-by: Jan Fiedler <[email protected]>
flyteorg · Jul 25, 2024 · ed10c89 · ed10c89
1 parent 3c7f358
commit ed10c89
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/flytekit/clis/sdk_in_container/run.py b/flytekit/clis/sdk_in_container/run.py
@@ -595,7 +595,7 @@ def _get_params(
         defaults: typing.Optional[typing.Dict[str, Parameter]] = None,
     ) -> typing.List["click.Parameter"]:
         params = []
-        flyte_ctx = context_manager.FlyteContextManager.current_context()
+        flyte_ctx = ctx.obj.remote_instance().context
         for name, var in inputs.items():
             if fixed and name in fixed:
                 continue
@@ -609,6 +609,7 @@ def _get_params(
         return params
 
     def get_params(self, ctx: click.Context) -> typing.List["click.Parameter"]:
+        ctx.obj.remote = True
         if not self.params:
             self.params = []
             entity = self._fetch_entity(ctx)