Skip to content

Commit

Permalink
Lint fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
@dagardner-nv
dagardner-nv committed Sep 16, 2024
1 parent dc1968d commit 2a2b310
Show file tree
Hide file tree
Showing 7 changed files with 167 additions and 915 deletions.
2 changes: 2 additions & 0 deletions examples/developer_guide/2_2_rabbitmq/rabbitmq_source_stage_deco.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -42,6 +42,8 @@ def rabbitmq_source(subscription: mrc.Subscription,
Parameters
----------
subscription : mrc.Subscription
Subscription object used to determine if the pipeline is still running.
host : str
Hostname or IP of the RabbitMQ server.
exchange : str
Expand Down
264 changes: 66 additions & 198 deletions python/morpheus/morpheus/_lib/common/__init__.pyi
View file
Original file line number Diff line number Diff line change
Expand Up @@ -26,31 +26,14 @@ __all__ = [


class FiberQueue():

def __enter__(self) -> FiberQueue:
...

def __exit__(self, arg0: object, arg1: object, arg2: object) -> None:
...

def __init__(self, max_size: int) -> None:
...

def close(self) -> None:
...

def get(self, block: bool = True, timeout: float = 0.0) -> object:
...

def is_closed(self) -> bool:
...

def put(self, item: object, block: bool = True, timeout: float = 0.0) -> None:
...

def __enter__(self) -> FiberQueue: ...
def __exit__(self, arg0: object, arg1: object, arg2: object) -> None: ...
def __init__(self, max_size: int) -> None: ...
def close(self) -> None: ...
def get(self, block: bool = True, timeout: float = 0.0) -> object: ...
def is_closed(self) -> bool: ...
def put(self, item: object, block: bool = True, timeout: float = 0.0) -> None: ...
pass


class FileTypes():
"""
The type of files that the `FileSourceStage` can read and `WriteToFileStage` can write. Use 'auto' to determine from the file extension.
Expand All @@ -65,54 +48,31 @@ class FileTypes():
PARQUET
"""

def __eq__(self, other: object) -> bool:
...

def __getstate__(self) -> int:
...

def __hash__(self) -> int:
...

def __index__(self) -> int:
...

def __init__(self, value: int) -> None:
...

def __int__(self) -> int:
...

def __ne__(self, other: object) -> bool:
...

def __repr__(self) -> str:
...

def __setstate__(self, state: int) -> None:
...

def __eq__(self, other: object) -> bool: ...
def __getstate__(self) -> int: ...
def __hash__(self) -> int: ...
def __index__(self) -> int: ...
def __init__(self, value: int) -> None: ...
def __int__(self) -> int: ...
def __ne__(self, other: object) -> bool: ...
def __repr__(self) -> str: ...
def __setstate__(self, state: int) -> None: ...
@property
def name(self) -> str:
"""
:type: str
"""

@property
def value(self) -> int:
"""
:type: int
"""

Auto: morpheus._lib.common.FileTypes # value = <FileTypes.Auto: 0>
CSV: morpheus._lib.common.FileTypes # value = <FileTypes.CSV: 2>
JSON: morpheus._lib.common.FileTypes # value = <FileTypes.JSON: 1>
PARQUET: morpheus._lib.common.FileTypes # value = <FileTypes.PARQUET: 3>
__members__: dict # value = {'Auto': <FileTypes.Auto: 0>, 'JSON': <FileTypes.JSON: 1>, 'CSV': <FileTypes.CSV: 2>, 'PARQUET': <FileTypes.PARQUET: 3>}
Auto: morpheus._lib.common.FileTypes # value = <FileTypes.Auto: 0>
CSV: morpheus._lib.common.FileTypes # value = <FileTypes.CSV: 2>
JSON: morpheus._lib.common.FileTypes # value = <FileTypes.JSON: 1>
PARQUET: morpheus._lib.common.FileTypes # value = <FileTypes.PARQUET: 3>
__members__: dict # value = {'Auto': <FileTypes.Auto: 0>, 'JSON': <FileTypes.JSON: 1>, 'CSV': <FileTypes.CSV: 2>, 'PARQUET': <FileTypes.PARQUET: 3>}
pass


class FilterSource():
"""
Enum to indicate which source the FilterDetectionsStage should operate on.
Expand All @@ -125,108 +85,51 @@ class FilterSource():
DATAFRAME
"""

def __eq__(self, other: object) -> bool:
...

def __getstate__(self) -> int:
...

def __hash__(self) -> int:
...

def __index__(self) -> int:
...

def __init__(self, value: int) -> None:
...

def __int__(self) -> int:
...

def __ne__(self, other: object) -> bool:
...

def __repr__(self) -> str:
...

def __setstate__(self, state: int) -> None:
...

def __eq__(self, other: object) -> bool: ...
def __getstate__(self) -> int: ...
def __hash__(self) -> int: ...
def __index__(self) -> int: ...
def __init__(self, value: int) -> None: ...
def __int__(self) -> int: ...
def __ne__(self, other: object) -> bool: ...
def __repr__(self) -> str: ...
def __setstate__(self, state: int) -> None: ...
@property
def name(self) -> str:
"""
:type: str
"""

@property
def value(self) -> int:
"""
:type: int
"""

Auto: morpheus._lib.common.FilterSource # value = <FilterSource.Auto: 0>
DATAFRAME: morpheus._lib.common.FilterSource # value = <FilterSource.DATAFRAME: 2>
TENSOR: morpheus._lib.common.FilterSource # value = <FilterSource.TENSOR: 1>
__members__: dict # value = {'Auto': <FilterSource.Auto: 0>, 'TENSOR': <FilterSource.TENSOR: 1>, 'DATAFRAME': <FilterSource.DATAFRAME: 2>}
Auto: morpheus._lib.common.FilterSource # value = <FilterSource.Auto: 0>
DATAFRAME: morpheus._lib.common.FilterSource # value = <FilterSource.DATAFRAME: 2>
TENSOR: morpheus._lib.common.FilterSource # value = <FilterSource.TENSOR: 1>
__members__: dict # value = {'Auto': <FilterSource.Auto: 0>, 'TENSOR': <FilterSource.TENSOR: 1>, 'DATAFRAME': <FilterSource.DATAFRAME: 2>}
pass


class HttpEndpoint():

def __init__(self, py_parse_fn: function, url: str, method: str) -> None:
...

def __init__(self, py_parse_fn: function, url: str, method: str) -> None: ...
pass


class HttpServer():

def __enter__(self) -> HttpServer:
...

def __exit__(self, arg0: object, arg1: object, arg2: object) -> None:
...

def __init__(self,
endpoints: typing.List[HttpEndpoint],
bind_address: str = '127.0.0.1',
port: int = 8080,
num_threads: int = 1,
max_payload_size: int = 10485760,
request_timeout: int = 30) -> None:
...

def is_running(self) -> bool:
...

def start(self) -> None:
...

def stop(self) -> None:
...

def __enter__(self) -> HttpServer: ...
def __exit__(self, arg0: object, arg1: object, arg2: object) -> None: ...
def __init__(self, endpoints: typing.List[HttpEndpoint], bind_address: str = '127.0.0.1', port: int = 8080, num_threads: int = 1, max_payload_size: int = 10485760, request_timeout: int = 30) -> None: ...
def is_running(self) -> bool: ...
def start(self) -> None: ...
def stop(self) -> None: ...
pass


class Tensor():

@staticmethod
def from_cupy(arg0: object) -> Tensor:
...

def to_cupy(self) -> object:
...

def from_cupy(arg0: object) -> Tensor: ...
def to_cupy(self) -> object: ...
@property
def __cuda_array_interface__(self) -> dict:
"""
:type: dict
"""

pass


class TypeId():
"""
Supported Morpheus types
Expand Down Expand Up @@ -259,87 +162,52 @@ class TypeId():
STRING
"""

def __eq__(self, other: object) -> bool:
...

def __getstate__(self) -> int:
...

def __hash__(self) -> int:
...

def __index__(self) -> int:
...

def __init__(self, value: int) -> None:
...

def __int__(self) -> int:
...

def __ne__(self, other: object) -> bool:
...

def __repr__(self) -> str:
...

def __setstate__(self, state: int) -> None:
...

def __eq__(self, other: object) -> bool: ...
def __getstate__(self) -> int: ...
def __hash__(self) -> int: ...
def __index__(self) -> int: ...
def __init__(self, value: int) -> None: ...
def __int__(self) -> int: ...
def __ne__(self, other: object) -> bool: ...
def __repr__(self) -> str: ...
def __setstate__(self, state: int) -> None: ...
@property
def name(self) -> str:
"""
:type: str
"""

@property
def value(self) -> int:
"""
:type: int
"""

BOOL8: morpheus._lib.common.TypeId # value = <TypeId.BOOL8: 11>
EMPTY: morpheus._lib.common.TypeId # value = <TypeId.EMPTY: 0>
FLOAT32: morpheus._lib.common.TypeId # value = <TypeId.FLOAT32: 9>
FLOAT64: morpheus._lib.common.TypeId # value = <TypeId.FLOAT64: 10>
INT16: morpheus._lib.common.TypeId # value = <TypeId.INT16: 2>
INT32: morpheus._lib.common.TypeId # value = <TypeId.INT32: 3>
INT64: morpheus._lib.common.TypeId # value = <TypeId.INT64: 4>
INT8: morpheus._lib.common.TypeId # value = <TypeId.INT8: 1>
STRING: morpheus._lib.common.TypeId # value = <TypeId.STRING: 12>
UINT16: morpheus._lib.common.TypeId # value = <TypeId.UINT16: 6>
UINT32: morpheus._lib.common.TypeId # value = <TypeId.UINT32: 7>
UINT64: morpheus._lib.common.TypeId # value = <TypeId.UINT64: 8>
UINT8: morpheus._lib.common.TypeId # value = <TypeId.UINT8: 5>
__members__: dict # value = {'EMPTY': <TypeId.EMPTY: 0>, 'INT8': <TypeId.INT8: 1>, 'INT16': <TypeId.INT16: 2>, 'INT32': <TypeId.INT32: 3>, 'INT64': <TypeId.INT64: 4>, 'UINT8': <TypeId.UINT8: 5>, 'UINT16': <TypeId.UINT16: 6>, 'UINT32': <TypeId.UINT32: 7>, 'UINT64': <TypeId.UINT64: 8>, 'FLOAT32': <TypeId.FLOAT32: 9>, 'FLOAT64': <TypeId.FLOAT64: 10>, 'BOOL8': <TypeId.BOOL8: 11>, 'STRING': <TypeId.STRING: 12>}
BOOL8: morpheus._lib.common.TypeId # value = <TypeId.BOOL8: 11>
EMPTY: morpheus._lib.common.TypeId # value = <TypeId.EMPTY: 0>
FLOAT32: morpheus._lib.common.TypeId # value = <TypeId.FLOAT32: 9>
FLOAT64: morpheus._lib.common.TypeId # value = <TypeId.FLOAT64: 10>
INT16: morpheus._lib.common.TypeId # value = <TypeId.INT16: 2>
INT32: morpheus._lib.common.TypeId # value = <TypeId.INT32: 3>
INT64: morpheus._lib.common.TypeId # value = <TypeId.INT64: 4>
INT8: morpheus._lib.common.TypeId # value = <TypeId.INT8: 1>
STRING: morpheus._lib.common.TypeId # value = <TypeId.STRING: 12>
UINT16: morpheus._lib.common.TypeId # value = <TypeId.UINT16: 6>
UINT32: morpheus._lib.common.TypeId # value = <TypeId.UINT32: 7>
UINT64: morpheus._lib.common.TypeId # value = <TypeId.UINT64: 8>
UINT8: morpheus._lib.common.TypeId # value = <TypeId.UINT8: 5>
__members__: dict # value = {'EMPTY': <TypeId.EMPTY: 0>, 'INT8': <TypeId.INT8: 1>, 'INT16': <TypeId.INT16: 2>, 'INT32': <TypeId.INT32: 3>, 'INT64': <TypeId.INT64: 4>, 'UINT8': <TypeId.UINT8: 5>, 'UINT16': <TypeId.UINT16: 6>, 'UINT32': <TypeId.UINT32: 7>, 'UINT64': <TypeId.UINT64: 8>, 'FLOAT32': <TypeId.FLOAT32: 9>, 'FLOAT64': <TypeId.FLOAT64: 10>, 'BOOL8': <TypeId.BOOL8: 11>, 'STRING': <TypeId.STRING: 12>}
pass


@typing.overload
def determine_file_type(filename: os.PathLike) -> FileTypes:
pass


@typing.overload
def determine_file_type(filename: str) -> FileTypes:
pass


def read_file_to_df(filename: str, file_type: FileTypes = FileTypes.Auto) -> object:
pass


def typeid_is_fully_supported(arg0: TypeId) -> bool:
pass


def typeid_to_numpy_str(arg0: TypeId) -> str:
pass


def write_df_to_file(df: object, filename: str, file_type: FileTypes = FileTypes.Auto, **kwargs) -> None:
pass


__version__ = '24.10.0'
Loading

0 comments on commit 2a2b310

Please sign in to comment.