Skip to content
This repository has been archived by the owner on Jul 10, 2024. It is now read-only.

Commit

Permalink
try to make codestyle checker happy
Browse files Browse the repository at this point in the history
  • Loading branch information
ifndef012 committed Jul 18, 2020
1 parent 9ff2f8d commit 42d5091
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ def _locate_sample_offsets(cls, data_uri: str, n_jobs: int) -> np.ndarray:
@classmethod
def _locate_sample_offsets_job(
cls, data_uri: str, task: Tuple[int, Tuple[int, int]]) -> List[int]:
job_id, (start, end) = task
_, (start, end) = task
offsets = [start]
with open_buffered_file_reader(data_uri) as infile:
infile.seek(start, os.SEEK_SET)
Expand Down
2 changes: 0 additions & 2 deletions submarine-sdk/pysubmarine/submarine/ml/pytorch/layers/core.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,6 @@
# See the License for the specific language governing permissions and
# limitations under the License.

from itertools import accumulate

import torch
from torch import nn

Expand Down
5 changes: 2 additions & 3 deletions submarine-sdk/pysubmarine/submarine/utils/fileio.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@
# limitations under the License.

from pyarrow import fs
from pyarrow.lib import NativeFile

import io
from urllib.parse import urlparse
Expand Down Expand Up @@ -52,12 +51,12 @@ def write_file(buffer: io.BytesIO,
output_stream.write(buffer.getbuffer())


def open_input_file(uri: str) -> NativeFile:
def open_input_file(uri: str):
filesystem, path = _parse_uri(uri)
return filesystem.open_input_file(path)


def open_output_stream(uri: str) -> NativeFile:
def open_output_stream(uri: str):
filesystem, path = _parse_uri(uri)
return filesystem.open_output_stream(path)

Expand Down

0 comments on commit 42d5091

Please sign in to comment.