From 614ab3447b419b6fe86ff9e4e70add657f166c1b Mon Sep 17 00:00:00 2001 From: JulienPeloton Date: Thu, 5 Dec 2024 15:01:13 +0100 Subject: [PATCH] PEP8 --- apps/utils/client.py | 9 +++++++-- apps/utils/decoding.py | 1 + 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/apps/utils/client.py b/apps/utils/client.py index 96a130b..1209292 100644 --- a/apps/utils/client.py +++ b/apps/utils/client.py @@ -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 @@ -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"] @@ -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 diff --git a/apps/utils/decoding.py b/apps/utils/decoding.py index 078d029..0ec07fa 100644 --- a/apps/utils/decoding.py +++ b/apps/utils/decoding.py @@ -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