diff --git a/pyproject.toml b/pyproject.toml
index d73e2983..4f9e0ddf 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -8,10 +8,9 @@ license = "MIT"
 [tool.poetry.dependencies]
 python = "^3.7.1"
 postgrest-py = "^0.3.2"
-realtime-py="^0.1.0"
+realtime-py="^0.1.2"
 gotrue="0.1.2"
 pytest="6.2.2"
-supabase-realtime-py="0.1.1a0"
 
 [tool.poetry.dev-dependencies]
 
diff --git a/supabase_py/lib/realtime_client.py b/supabase_py/lib/realtime_client.py
index 190b0e65..3554e41a 100644
--- a/supabase_py/lib/realtime_client.py
+++ b/supabase_py/lib/realtime_client.py
@@ -5,7 +5,7 @@
 
 
 class SupabaseRealtimeClient:
-    def __init__(self, socket: Type[Socket], schema: str, table_name: str):
+    def __init__(self, socket: Socket, schema: str, table_name: str):
         topic = (
             f"realtime:{schema}"
             if table_name == "*"
@@ -18,7 +18,7 @@ def get_payload_records(self, payload: Any):
         if payload.type == "INSERT" or payload.type == "UPDATE":
             records.new = payload.record
             convert_change_data(payload.columns, payload.record)
-        if (payload.type === 'UPDATE' or payload.type === 'DELETE'):
+        if (payload.type == 'UPDATE' or payload.type == 'DELETE'):
             records.old = payload.record
             convert_change_data(payload.columns, payload.old_record)
         return records