Skip to content

Commit

Permalink
PEP8
Browse files Browse the repository at this point in the history
  • Loading branch information
JulienPeloton committed Dec 5, 2024
1 parent 6e5e775 commit 614ab34
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 2 deletions.
9 changes: 7 additions & 2 deletions apps/utils/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@
# See the License for the specific language governing permissions and
# limitations under the License.
"""Utilities to work with the Fink HBase client"""

from py4j.java_gateway import JavaGateway
import os

Expand Down Expand Up @@ -53,7 +54,9 @@ def connect_to_hbase_table(
)

gateway = JavaGateway(auto_convert=True)
client = gateway.jvm.com.Lomikel.HBaser.HBaseClient(args["HBASEIP"], args["ZOOPORT"])
client = gateway.jvm.com.Lomikel.HBaser.HBaseClient(
args["HBASEIP"], args["ZOOPORT"]
)

if schema_name is None:
schema_name = args["SCHEMAVER"]
Expand Down Expand Up @@ -106,7 +109,9 @@ def create_or_update_hbase_table(
)

gateway = JavaGateway(auto_convert=True)
client = gateway.jvm.com.Lomikel.HBaser.HBaseClient(args["HBASEIP"], args["ZOOPORT"])
client = gateway.jvm.com.Lomikel.HBaser.HBaseClient(
args["HBASEIP"], args["ZOOPORT"]
)

if create:
# Create the table and connect without schema
Expand Down
1 change: 1 addition & 0 deletions apps/utils/decoding.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@
# See the License for the specific language governing permissions and
# limitations under the License.
"""Utilities to decode data from the HBase client"""

from py4j.java_gateway import JavaGateway
import json
import pandas as pd
Expand Down

0 comments on commit 614ab34

Please sign in to comment.