Maintaining the Openflow Connector for Shopify¶
Note
This connector is subject to the Snowflake Connector Terms.
This topic describes maintenance tasks for the Openflow Connector for Shopify, including how to force a full reload of connector state.
Force a full reload¶
The connector maintains an internal state to track which objects have been bulk-loaded and the incremental watermark for each object type. In some situations, you might need to force the connector to perform a fresh bulk load, for example, after resolving a data issue or after the connector has been stopped for an extended period.
Reload all objects¶
To force a full reload for all objects:
- Stop all processors in the flow by right-clicking on the connector process group and selecting Stop.
- Ensure that no in-flight FlowFiles are being processed. You can verify this by checking that all queues in the flow are empty.
- Right-click on the canvas and select Disable all controller services.
- Go to Controller services and locate the Shopify State Service.
- Select the menu for Shopify State Service, then select View state and select Clear state.
- Right-click on the canvas and select Enable all controller services, then start all processors to resume the connector.
The connector treats a cleared state as a fresh start and performs a bulk load for all configured objects on the next execution.
Reload a specific object¶
To re-ingest a single object type from scratch without affecting other objects:
- Stop all processors in the flow.
- Ensure all queues are empty.
- Right-click on the canvas and select Disable all controller services.
- Go to Controller services and locate the Shopify State Service.
- Select the menu for Shopify State Service, then select View state.
- Select the trash icon next to the specific object type (for example,
orders) to delete its state entry. - Re-enable all controller services and start the flow.
The connector performs a bulk load for that object type and then resumes incremental updates, while other objects continue from their existing watermark.