From ee42367951a58f674e001a9948fb1da9973786ce Mon Sep 17 00:00:00 2001 From: Kevin Su Date: Wed, 4 Sep 2024 14:35:38 -0700 Subject: [PATCH] fix backfill command Signed-off-by: Kevin Su --- flytekit/remote/remote.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/flytekit/remote/remote.py b/flytekit/remote/remote.py index 2cb8103647..2c4f836a4a 100644 --- a/flytekit/remote/remote.py +++ b/flytekit/remote/remote.py @@ -781,9 +781,13 @@ async def _serialize_and_register( # serial register cp_other_entities = OrderedDict(filter(lambda x: not isinstance(x[1], task_models.TaskSpec), m.items())) for entity, cp_entity in cp_other_entities.items(): - identifiers_or_exceptions.append( - self.raw_register(cp_entity, serialization_settings, version, og_entity=entity) - ) + try: + identifiers_or_exceptions.append( + self.raw_register(cp_entity, serialization_settings, version, og_entity=entity) + ) + except RegistrationSkipped as e: + logger.info(f"Skipping registration... {e}") + continue return identifiers_or_exceptions[-1] def register_task(