Skip to content

Commit 4108022

Browse files
committed
Adding additional logs to OpenLineageIn
1 parent 4eba25b commit 4108022

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

function-app/adb-to-purview/src/Function.Domain/Helpers/OlProcessing/ValidateOlEvent.cs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,17 +40,20 @@ public ValidateOlEvent(ILoggerFactory loggerFactory)
4040
/// <param name="olEvent">OpenLineage Event message</param>
4141
/// <returns>true if input is valid, false if not</returns>
4242
public bool Validate(Event olEvent){
43+
_log.LogInformation($"Validating input of an event with {olEvent.Inputs.Count} inputs and {olEvent.Outputs.Count} outputs");
4344
if (olEvent.Inputs.Count > 0 && olEvent.Outputs.Count > 0)
4445
{
4546
// Need to rework for multiple inputs and outputs in one packet - possibly combine and then hash
4647
if (InOutEqual(olEvent))
4748
{
49+
_log.LogWarning($"Event considered NOT valid due to inputs and outputs being equal");
4850
return false;
4951
}
5052
if (olEvent.EventType == "START")
5153
{
5254
if (olEvent.Run.Facets.EnvironmentProperties == null)
5355
{
56+
_log.LogWarning($"Start Event considered NOT valid due to missing Databricks Envrionment Properties");
5457
return false;
5558
}
5659
return true;
@@ -61,9 +64,11 @@ public bool Validate(Event olEvent){
6164
}
6265
else
6366
{
67+
_log.LogWarning($"Event considered NOT valid due to not matching any other condition");
6468
return false;
6569
}
6670
}
71+
_log.LogWarning($"Event considered NOT valid due to not matching any other condition");
6772
return false;
6873
}
6974

0 commit comments

Comments
 (0)