Hello @Noah Gilbert
It's possible that the metrics for the sink are not being captured correctly. If a sink has zero rows written, it will not show up in metrics. Existence can be verified using the contains
function. For example, contains(activity('dataflowActivity').output.runStatus.metrics, 'sink1')
will check whether any rows were written to sink1.
To get the number of rows written to a sink named 'sink1' in an activity named 'dataflowActivity', use @activity('dataflowActivity').output.runStatus.metrics.sink1.rowsWritten
.
To get the number of rows read from a source named 'source1' that was used in that sink, use @activity('dataflowActivity').output.runStatus.metrics.sink1.sources.source1.rowsRead
.
If you are still having issues, it may be helpful to check the debug logs for any errors or warnings related to the sink. You can also try running the data flow from a pipeline and checking the output in the pipeline run details to see if the rows are being written correctly.
I hope that this response has addressed your query and helped you overcome your challenges. If so, please mark this response as Answered. This will not only acknowledge our efforts, but also assist other community members who may be looking for similar solutions.