Example 8: Resume a Previously Interrupted Feature Process using Filter Manager - Teradata Package for Python

For this example, assume the feature process run in example 7 got interrupted after processing filter_id=2.

Resume the process for remaining filter_id's in the filter manager.

>>> fp = FeatureProcess(repo="vfs_v1",
...                     data_domain='sales',
...                     object=df2,
...                     entity='id',
...                     features=['masters', 'gpa', 'stats', 'admitted'])

>>> fp.run(filter_manager=fm, resume=True)

Process '07741d30-4d47-11f1-a487-cf2ce15f3444' started.
Resume enabled for ingesting features with FilterManager 'stats_filter_manager'
Resuming from filter_id=3, last completed filter_id=2.
Ingesting the features for filter_id=3: {"stats":"Novice"} to catalog.
Process '07741d30-4d47-11f1-a487-cf2ce15f3444' completed.
True

In case all the features are ingested successfully and resume is set to True.

>>> fp = FeatureProcess(repo="vfs_v1",
...                     data_domain='sales',
...                     object=df2,
...                     entity='id',
...                     features=['masters', 'gpa', 'stats', 'admitted'])

>>> fp.run(filter_manager=fm, resume=True)

Process '07741d30-4d47-11f1-a487-cf2ce15f3444' started.
Resume enabled for ingesting features with FilterManager 'stats_filter_manager'.
All features are already ingested in catalog.
Process '07741d30-4d47-11f1-a487-cf2ce15f3444' completed.
True