remove debuggings

Signed-off-by: novahow <[email protected]>

flytekit/core/base_task.py

@@ -283,7 +283,6 @@ def local_execute(
         #  Promises as essentially inputs from previous task executions
         #  native constants are just bound to this specific task (default values for a task input)
         #  Also along with promises and constants, there could be dictionary or list of promises or constants
-        # breakpoint()
         try:
             literals = translate_inputs_to_literals(
                 ctx,
@@ -334,7 +333,6 @@ def local_execute(
             # This code should mirror the call to `sandbox_execute` in the above cache case.
             # Code is simpler with duplication and less metaprogramming, but introduces regressions
             # if one is changed and not the other.
-            # breakpoint()
             outputs_literal_map = self.sandbox_execute(ctx, input_literal_map)
 
         if inspect.iscoroutine(outputs_literal_map):
@@ -358,7 +356,6 @@ def local_execute(
         return create_task_output(vals, self.python_interface)
 
     def __call__(self, *args: object, **kwargs: object) -> Union[Tuple[Promise], Promise, VoidPromise, Tuple, None]:
-        # breakpoint()
         return flyte_entity_call_handler(self, *args, **kwargs)  # type: ignore
 
     def compile(self, ctx: FlyteContext, *args, **kwargs):

flytekit/core/promise.py

@@ -390,7 +390,6 @@ def __init__(
             self._ref = val
             self._promise_ready = False
             self._val = None
-        # breakpoint()
         self._awaitable = awaitable
 
     def __hash__(self):
@@ -1241,7 +1240,6 @@ def flyte_entity_call_handler(
     #. Start a local execution - This means that we're not already in a local workflow execution, which means that
        we should expect inputs to be native Python values and that we should return Python native values.
     """
-    # breakpoint()
     # Make sure arguments are part of interface
     for k, v in kwargs.items():
         if k not in entity.python_interface.inputs:

flytekit/core/python_function_task.py

@@ -195,7 +195,6 @@ def execute(self, **kwargs) -> Any:
         This method will be invoked to execute the task. If you do decide to override this method you must also
         handle dynamic tasks or you will no longer be able to use the task as a dynamic task generator.
         """
-        # breakpoint()
         if self.execution_mode == self.ExecutionBehavior.DEFAULT:
             return exception_scopes.user_entry_point(self._task_function)(**kwargs)
         elif self.execution_mode == self.ExecutionBehavior.EAGER:

flytekit/core/workflow.py

@@ -724,7 +724,6 @@ def _wrapped_function(**kwargs):
                 try:
                     # HACK, not sure if the nest_asyncio implementation uses thread since ctx is not thread-safe
                     loop = asyncio.get_running_loop()
-                    # breakpoint()
                     nest_asyncio.apply()
 
                     return loop.run_until_complete(self._workflow_function(**kwargs))