diff --git a/slack_bolt/context/complete/async_complete.py b/slack_bolt/context/complete/async_complete.py
index fe3d796d1..bb81c2d4a 100644
--- a/slack_bolt/context/complete/async_complete.py
+++ b/slack_bolt/context/complete/async_complete.py
@@ -7,6 +7,7 @@
 class AsyncComplete:
     client: AsyncWebClient
     function_execution_id: Optional[str]
+    _called: bool
 
     def __init__(
         self,
@@ -15,6 +16,7 @@ def __init__(
     ):
         self.client = client
         self.function_execution_id = function_execution_id
+        self._called = False
 
     async def __call__(self, outputs: Optional[Dict[str, Any]] = None) -> AsyncSlackResponse:
         """Signal the successful completion of the custom function.
@@ -31,6 +33,15 @@ async def __call__(self, outputs: Optional[Dict[str, Any]] = None) -> AsyncSlack
         if self.function_execution_id is None:
             raise ValueError("complete is unsupported here as there is no function_execution_id")
 
+        self._called = True
         return await self.client.functions_completeSuccess(
             function_execution_id=self.function_execution_id, outputs=outputs or {}
         )
+
+    def has_been_called(self) -> bool:
+        """Check if this complete function has been called.
+
+        Returns:
+            bool: True if the complete function has been called, False otherwise.
+        """
+        return self._called
diff --git a/slack_bolt/context/complete/complete.py b/slack_bolt/context/complete/complete.py
index acba3a412..dc9382384 100644
--- a/slack_bolt/context/complete/complete.py
+++ b/slack_bolt/context/complete/complete.py
@@ -7,6 +7,7 @@
 class Complete:
     client: WebClient
     function_execution_id: Optional[str]
+    _called: bool
 
     def __init__(
         self,
@@ -15,6 +16,7 @@ def __init__(
     ):
         self.client = client
         self.function_execution_id = function_execution_id
+        self._called = False
 
     def __call__(self, outputs: Optional[Dict[str, Any]] = None) -> SlackResponse:
         """Signal the successful completion of the custom function.
@@ -31,4 +33,13 @@ def __call__(self, outputs: Optional[Dict[str, Any]] = None) -> SlackResponse:
         if self.function_execution_id is None:
             raise ValueError("complete is unsupported here as there is no function_execution_id")
 
+        self._called = True
         return self.client.functions_completeSuccess(function_execution_id=self.function_execution_id, outputs=outputs or {})
+
+    def has_been_called(self) -> bool:
+        """Check if this complete function has been called.
+
+        Returns:
+            bool: True if the complete function has been called, False otherwise.
+        """
+        return self._called
diff --git a/slack_bolt/context/fail/async_fail.py b/slack_bolt/context/fail/async_fail.py
index 10a39f735..da01067ba 100644
--- a/slack_bolt/context/fail/async_fail.py
+++ b/slack_bolt/context/fail/async_fail.py
@@ -7,6 +7,7 @@
 class AsyncFail:
     client: AsyncWebClient
     function_execution_id: Optional[str]
+    _called: bool
 
     def __init__(
         self,
@@ -15,6 +16,7 @@ def __init__(
     ):
         self.client = client
         self.function_execution_id = function_execution_id
+        self._called = False
 
     async def __call__(self, error: str) -> AsyncSlackResponse:
         """Signal that the custom function failed to complete.
@@ -31,4 +33,13 @@ async def __call__(self, error: str) -> AsyncSlackResponse:
         if self.function_execution_id is None:
             raise ValueError("fail is unsupported here as there is no function_execution_id")
 
+        self._called = True
         return await self.client.functions_completeError(function_execution_id=self.function_execution_id, error=error)
+
+    def has_been_called(self) -> bool:
+        """Check if this fail function has been called.
+
+        Returns:
+            bool: True if the fail function has been called, False otherwise.
+        """
+        return self._called
diff --git a/slack_bolt/context/fail/fail.py b/slack_bolt/context/fail/fail.py
index 483bcebc3..9b04f6118 100644
--- a/slack_bolt/context/fail/fail.py
+++ b/slack_bolt/context/fail/fail.py
@@ -7,6 +7,7 @@
 class Fail:
     client: WebClient
     function_execution_id: Optional[str]
+    _called: bool
 
     def __init__(
         self,
@@ -15,6 +16,7 @@ def __init__(
     ):
         self.client = client
         self.function_execution_id = function_execution_id
+        self._called = False
 
     def __call__(self, error: str) -> SlackResponse:
         """Signal that the custom function failed to complete.
@@ -31,4 +33,13 @@ def __call__(self, error: str) -> SlackResponse:
         if self.function_execution_id is None:
             raise ValueError("fail is unsupported here as there is no function_execution_id")
 
+        self._called = True
         return self.client.functions_completeError(function_execution_id=self.function_execution_id, error=error)
+
+    def has_been_called(self) -> bool:
+        """Check if this fail function has been called.
+
+        Returns:
+            bool: True if the fail function has been called, False otherwise.
+        """
+        return self._called
diff --git a/tests/scenario_tests/test_function.py b/tests/scenario_tests/test_function.py
index 0a2152892..5a4fc2685 100644
--- a/tests/scenario_tests/test_function.py
+++ b/tests/scenario_tests/test_function.py
@@ -300,16 +300,20 @@ def reverse(body, event, context, client, complete, inputs):
     assert context.client.token == "xwfp-valid"
     assert client.token == "xwfp-valid"
     assert complete.client.token == "xwfp-valid"
+    assert complete.has_been_called() is False
     complete(
         outputs={"reverseString": "olleh"},
     )
+    assert complete.has_been_called() is True
 
 
 def reverse_error(body, event, fail):
     assert body == function_body
     assert event == function_body["event"]
     assert fail.function_execution_id == "Fx111"
+    assert fail.has_been_called() is False
     fail(error="there was an error")
+    assert fail.has_been_called() is True
 
 
 def complete_it(body, event, complete):
diff --git a/tests/scenario_tests_async/test_function.py b/tests/scenario_tests_async/test_function.py
index 3f8b7a722..142cc1d6c 100644
--- a/tests/scenario_tests_async/test_function.py
+++ b/tests/scenario_tests_async/test_function.py
@@ -312,18 +312,22 @@ async def reverse(body, event, client, context, complete, inputs):
     assert context.client.token == "xwfp-valid"
     assert client.token == "xwfp-valid"
     assert complete.client.token == "xwfp-valid"
+    assert complete.has_been_called() is False
     await complete(
         outputs={"reverseString": "olleh"},
     )
+    assert complete.has_been_called() is True
 
 
 async def reverse_error(body, event, fail):
     assert body == function_body
     assert event == function_body["event"]
     assert fail.function_execution_id == "Fx111"
+    assert fail.has_been_called() is False
     await fail(
         error="there was an error",
     )
+    assert fail.has_been_called() is True
 
 
 async def complete_it(body, event, complete):
diff --git a/tests/slack_bolt/context/test_complete.py b/tests/slack_bolt/context/test_complete.py
index a920c41eb..63a1d9f04 100644
--- a/tests/slack_bolt/context/test_complete.py
+++ b/tests/slack_bolt/context/test_complete.py
@@ -30,3 +30,12 @@ def test_complete_no_function_execution_id(self):
 
         with pytest.raises(ValueError):
             complete(outputs={"key": "value"})
+
+    def test_has_been_called_false_initially(self):
+        complete = Complete(client=self.web_client, function_execution_id="fn1111")
+        assert complete.has_been_called() is False
+
+    def test_has_been_called_true_after_complete(self):
+        complete = Complete(client=self.web_client, function_execution_id="fn1111")
+        complete(outputs={"key": "value"})
+        assert complete.has_been_called() is True
diff --git a/tests/slack_bolt/context/test_fail.py b/tests/slack_bolt/context/test_fail.py
index e4704d376..14348281f 100644
--- a/tests/slack_bolt/context/test_fail.py
+++ b/tests/slack_bolt/context/test_fail.py
@@ -30,3 +30,12 @@ def test_fail_no_function_execution_id(self):
 
         with pytest.raises(ValueError):
             fail(error="there was an error")
+
+    def test_has_been_called_false_initially(self):
+        fail = Fail(client=self.web_client, function_execution_id="fn1111")
+        assert fail.has_been_called() is False
+
+    def test_has_been_called_true_after_fail(self):
+        fail = Fail(client=self.web_client, function_execution_id="fn1111")
+        fail(error="there was an error")
+        assert fail.has_been_called() is True
diff --git a/tests/slack_bolt_async/context/test_async_complete.py b/tests/slack_bolt_async/context/test_async_complete.py
index f2fd115ec..b2a464f83 100644
--- a/tests/slack_bolt_async/context/test_async_complete.py
+++ b/tests/slack_bolt_async/context/test_async_complete.py
@@ -36,3 +36,14 @@ async def test_complete_no_function_execution_id(self):
 
         with pytest.raises(ValueError):
             await complete(outputs={"key": "value"})
+
+    @pytest.mark.asyncio
+    async def test_has_been_called_false_initially(self):
+        complete = AsyncComplete(client=self.web_client, function_execution_id="fn1111")
+        assert complete.has_been_called() is False
+
+    @pytest.mark.asyncio
+    async def test_has_been_called_true_after_complete(self):
+        complete = AsyncComplete(client=self.web_client, function_execution_id="fn1111")
+        await complete(outputs={"key": "value"})
+        assert complete.has_been_called() is True
diff --git a/tests/slack_bolt_async/context/test_async_fail.py b/tests/slack_bolt_async/context/test_async_fail.py
index 854bc7521..d4708927f 100644
--- a/tests/slack_bolt_async/context/test_async_fail.py
+++ b/tests/slack_bolt_async/context/test_async_fail.py
@@ -36,3 +36,14 @@ async def test_fail_no_function_execution_id(self):
 
         with pytest.raises(ValueError):
             await fail(error="there was an error")
+
+    @pytest.mark.asyncio
+    async def test_has_been_called_false_initially(self):
+        fail = AsyncFail(client=self.web_client, function_execution_id="fn1111")
+        assert fail.has_been_called() is False
+
+    @pytest.mark.asyncio
+    async def test_has_been_called_true_after_fail(self):
+        fail = AsyncFail(client=self.web_client, function_execution_id="fn1111")
+        await fail(error="there was an error")
+        assert fail.has_been_called() is True