Skip to content

Commit

Permalink
eh
Browse files Browse the repository at this point in the history
  • Loading branch information
smacke committed Feb 25, 2024
1 parent 2012da6 commit 9d58994
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions core/ipyflow/patches/__init__.py
Expand Up @@ -6,7 +6,6 @@

from ipyflow.patches.cloudpickle_patch import patch_cloudpickle_function_reduce
from ipyflow.patches.pyspark_patch import patch_pyspark_udf
from ipyflow.singletons import flow

logger = logging.getLogger(__name__)

Expand All @@ -26,15 +25,13 @@
def apply_patches(modname: str, module: ModuleType) -> None:
if modname in _patched_modules:
return
flow_ = flow()
for predicate, patch in _predicate_patch_pairs:
try:
if predicate(modname):
patch(module)
_patched_modules.add(modname)
except Exception: # noqa
if flow_.is_dev_mode:
logger.exception("Failed to apply patch to module %s", modname)
logger.exception("Failed to apply patch to module %s", modname)


def patch_all() -> None:
Expand Down

0 comments on commit 9d58994

Please sign in to comment.