File tree Expand file tree Collapse file tree 2 files changed +14
-14
lines changed
function-app/adb-to-purview/src/Function.Domain/Helpers/OlProcessing Expand file tree Collapse file tree 2 files changed +14
-14
lines changed Original file line number Diff line number Diff line change @@ -299,11 +299,11 @@ private bool IsStartEventEnvironment(Event olEvent)
299299 private bool isDataSourceV2Event ( Event olEvent ) {
300300 string [ ] special_cases = { "azurecosmos://" , "iceberg://" } ; // todo: make this configurable?
301301
302- foreach ( var outp in olEvent . Outputs )
302+ foreach ( var inp in olEvent . Inputs )
303303 {
304304 foreach ( var source in special_cases )
305305 {
306- if ( outp . NameSpace . StartsWith ( source ) ) return true ;
306+ if ( inp . NameSpace . StartsWith ( source ) ) return true ;
307307 }
308308 }
309309 return false ;
Original file line number Diff line number Diff line change @@ -29,23 +29,23 @@ public ValidateOlEvent(ILoggerFactory loggerFactory)
2929 _log = loggerFactory . CreateLogger < ValidateOlEvent > ( ) ;
3030 }
3131
32- /// <summary>
32+ /// <summary>
3333 /// Helper function to determine if the event is one of
3434 /// the data source v2 ones which needs us to save the
3535 /// inputs from the start event
3636 /// </summary>
37- private bool isDataSourceV2Event ( Event olEvent ) {
38- string [ ] special_cases = { "azurecosmos://" , "iceberg://" } ; // todo: make this configurable?
37+ // private bool isDataSourceV2Event(Event olEvent) {
38+ // string[] special_cases = {"azurecosmos://", "iceberg://"}; // todo: make this configurable?
3939
40- foreach ( var outp in olEvent . Outputs )
41- {
42- foreach ( var source in special_cases )
43- {
44- if ( outp . NameSpace . StartsWith ( source ) ) return true ;
45- }
46- }
47- return false ;
48- }
40+ // foreach (var outp in olEvent.Outputs)
41+ // {
42+ // foreach (var source in special_cases)
43+ // {
44+ // if (outp.NameSpace.StartsWith(source)) return true;
45+ // }
46+ // }
47+ // return false;
48+ // }
4949
5050 /// <summary>
5151 /// Performs initial validation of OpenLineage input
You can’t perform that action at this time.
0 commit comments