diff --git a/infrahub_sdk/groups.py b/infrahub_sdk/groups.py
new file mode 100644
index 00000000..f3fa341b
--- /dev/null
+++ b/infrahub_sdk/groups.py
@@ -0,0 +1,28 @@
+from typing import List
+
+from infrahub_sdk import InfrahubClient
+from infrahub_sdk.node import InfrahubNode
+
+
+async def group_add_subscriber(
+    client: InfrahubClient, group: InfrahubNode, subscribers: List[str], branch: str
+) -> dict:
+    subscribers_str = ["{ id: " + f'"{subscriber}"' + " }" for subscriber in subscribers]
+    query = """
+    mutation {
+        RelationshipAdd(
+            data: {
+                id: "%s",
+                name: "subscribers",
+                nodes: [ %s ]
+            }
+        ) {
+            ok
+        }
+    }
+    """ % (
+        group.id,
+        ", ".join(subscribers_str),
+    )
+
+    return await client.execute_graphql(query=query, branch_name=branch, tracker="mutation-relationshipadd")