Skip to content

Commit

Permalink
don't set workdir to /data when running SAT (#15024)
Browse files Browse the repository at this point in the history
* don't set workdir to /data

* remove debug log
  • Loading branch information
girarda authored Jul 26, 2022
1 parent 3e7b3da commit 9269cbf
Showing 1 changed file with 4 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -69,22 +69,22 @@ def call_spec(self, **kwargs) -> List[AirbyteMessage]:
return output

def call_check(self, config, **kwargs) -> List[AirbyteMessage]:
cmd = "check --config tap_config.json"
cmd = "check --config /data/tap_config.json"
output = list(self.run(cmd=cmd, config=config, **kwargs))
return output

def call_discover(self, config, **kwargs) -> List[AirbyteMessage]:
cmd = "discover --config tap_config.json"
cmd = "discover --config /data/tap_config.json"
output = list(self.run(cmd=cmd, config=config, **kwargs))
return output

def call_read(self, config, catalog, **kwargs) -> List[AirbyteMessage]:
cmd = "read --config tap_config.json --catalog catalog.json"
cmd = "read --config /data/tap_config.json --catalog /data/catalog.json"
output = list(self.run(cmd=cmd, config=config, catalog=catalog, **kwargs))
return output

def call_read_with_state(self, config, catalog, state, **kwargs) -> List[AirbyteMessage]:
cmd = "read --config tap_config.json --catalog catalog.json --state state.json"
cmd = "read --config /data/tap_config.json --catalog /data/catalog.json --state /data/state.json"
output = list(self.run(cmd=cmd, config=config, catalog=catalog, state=state, **kwargs))
return output

Expand All @@ -96,7 +96,6 @@ def run(self, cmd, config=None, state=None, catalog=None, raise_container_error:
container = self._client.containers.run(
image=self._image,
command=cmd,
working_dir="/data",
volumes=volumes,
network_mode="host",
detach=True,
Expand Down

0 comments on commit 9269cbf

Please sign in to comment.