File tree
41 files changed
+1338
-392
lines changed- airbyte_cdk
- models
- sources
- concurrent_source
- declarative
- extractors
- models
- parsers
- retrievers
- stream_slicers
- file_based
- file_types
- stream
- concurrent
- streams/concurrent
- utils
- test/mock_http
- unit_tests
- resource/http/response/file_api
- sources
- declarative/file
- file_based
- scenarios
- stream
- streams/concurrent
- scenarios
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
41 files changed
+1338
-392
lines changedLines changed: 1 addition & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
19 | 19 |
| |
20 | 20 |
| |
21 | 21 |
| |
| 22 | + | |
22 | 23 |
| |
23 | 24 |
| |
24 | 25 |
| |
|
Lines changed: 1 addition & 3 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
8 | 8 |
| |
9 | 9 |
| |
10 | 10 |
| |
11 |
| - | |
12 |
| - | |
13 | 11 |
| |
14 | 12 |
| |
15 | 13 |
| |
| |||
84 | 82 |
| |
85 | 83 |
| |
86 | 84 |
| |
87 |
| - | |
| 85 | + | |
88 | 86 |
| |
89 | 87 |
| |
90 | 88 |
|
Lines changed: 0 additions & 13 deletions
This file was deleted.
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
149 | 149 |
| |
150 | 150 |
| |
151 | 151 |
| |
152 |
| - | |
| 152 | + | |
153 | 153 |
| |
154 | 154 |
| |
155 | 155 |
| |
|
Lines changed: 8 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
28 | 28 |
| |
29 | 29 |
| |
30 | 30 |
| |
| 31 | + | |
31 | 32 |
| |
32 | 33 |
| |
33 | 34 |
| |
| |||
209 | 210 |
| |
210 | 211 |
| |
211 | 212 |
| |
| 213 | + | |
| 214 | + | |
| 215 | + | |
| 216 | + | |
212 | 217 |
| |
213 | 218 |
| |
214 | 219 |
| |
| |||
325 | 330 |
| |
326 | 331 |
| |
327 | 332 |
| |
| 333 | + | |
328 | 334 |
| |
329 | 335 |
| |
330 | 336 |
| |
| |||
356 | 362 |
| |
357 | 363 |
| |
358 | 364 |
| |
| 365 | + | |
359 | 366 |
| |
360 | 367 |
| |
361 | 368 |
| |
| |||
410 | 417 |
| |
411 | 418 |
| |
412 | 419 |
| |
| 420 | + | |
413 | 421 |
| |
414 | 422 |
| |
415 | 423 |
| |
|
Lines changed: 36 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1448 | 1448 |
| |
1449 | 1449 |
| |
1450 | 1450 |
| |
| 1451 | + | |
| 1452 | + | |
| 1453 | + | |
| 1454 | + | |
| 1455 | + | |
| 1456 | + | |
| 1457 | + | |
| 1458 | + | |
| 1459 | + | |
| 1460 | + | |
| 1461 | + | |
| 1462 | + | |
| 1463 | + | |
| 1464 | + | |
| 1465 | + | |
| 1466 | + | |
| 1467 | + | |
| 1468 | + | |
| 1469 | + | |
| 1470 | + | |
| 1471 | + | |
| 1472 | + | |
| 1473 | + | |
| 1474 | + | |
| 1475 | + | |
| 1476 | + | |
| 1477 | + | |
| 1478 | + | |
| 1479 | + | |
| 1480 | + | |
| 1481 | + | |
| 1482 | + | |
| 1483 | + | |
| 1484 | + | |
| 1485 | + | |
| 1486 | + | |
1451 | 1487 |
| |
1452 | 1488 |
| |
1453 | 1489 |
| |
|
Lines changed: 6 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
18 | 19 |
| |
19 | 20 |
| |
20 | 21 |
| |
| |||
42 | 43 |
| |
43 | 44 |
| |
44 | 45 |
| |
| 46 | + | |
45 | 47 |
| |
46 | 48 |
| |
47 | 49 |
| |
| |||
117 | 119 |
| |
118 | 120 |
| |
119 | 121 |
| |
120 |
| - | |
| 122 | + | |
| 123 | + | |
| 124 | + | |
| 125 | + | |
121 | 126 |
| |
122 | 127 |
| |
123 | 128 |
| |
|
Lines changed: 31 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
2066 | 2066 |
| |
2067 | 2067 |
| |
2068 | 2068 |
| |
| 2069 | + | |
| 2070 | + | |
| 2071 | + | |
| 2072 | + | |
| 2073 | + | |
| 2074 | + | |
| 2075 | + | |
| 2076 | + | |
| 2077 | + | |
| 2078 | + | |
| 2079 | + | |
| 2080 | + | |
| 2081 | + | |
| 2082 | + | |
| 2083 | + | |
| 2084 | + | |
| 2085 | + | |
| 2086 | + | |
| 2087 | + | |
| 2088 | + | |
| 2089 | + | |
| 2090 | + | |
| 2091 | + | |
| 2092 | + | |
| 2093 | + | |
2069 | 2094 |
| |
2070 | 2095 |
| |
2071 | 2096 |
| |
| |||
2124 | 2149 |
| |
2125 | 2150 |
| |
2126 | 2151 |
| |
| 2152 | + | |
| 2153 | + | |
| 2154 | + | |
| 2155 | + | |
| 2156 | + | |
2127 | 2157 |
| |
2128 | 2158 |
| |
2129 | 2159 |
| |
| |||
2617 | 2647 |
| |
2618 | 2648 |
| |
2619 | 2649 |
| |
| 2650 | + | |
2620 | 2651 |
| |
2621 | 2652 |
| |
2622 | 2653 |
| |
|
Lines changed: 39 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
106 | 106 |
| |
107 | 107 |
| |
108 | 108 |
| |
109 |
| - | |
110 | 109 |
| |
111 | 110 |
| |
112 | 111 |
| |
| |||
228 | 227 |
| |
229 | 228 |
| |
230 | 229 |
| |
| 230 | + | |
| 231 | + | |
| 232 | + | |
231 | 233 |
| |
232 | 234 |
| |
233 | 235 |
| |
| |||
479 | 481 |
| |
480 | 482 |
| |
481 | 483 |
| |
| 484 | + | |
482 | 485 |
| |
483 | 486 |
| |
484 | 487 |
| |
| |||
676 | 679 |
| |
677 | 680 |
| |
678 | 681 |
| |
| 682 | + | |
679 | 683 |
| |
680 | 684 |
| |
681 | 685 |
| |
| |||
1840 | 1844 |
| |
1841 | 1845 |
| |
1842 | 1846 |
| |
| 1847 | + | |
| 1848 | + | |
| 1849 | + | |
| 1850 | + | |
| 1851 | + | |
1843 | 1852 |
| |
1844 | 1853 |
| |
1845 | 1854 |
| |
| |||
1851 | 1860 |
| |
1852 | 1861 |
| |
1853 | 1862 |
| |
| 1863 | + | |
1854 | 1864 |
| |
1855 | 1865 |
| |
1856 | 1866 |
| |
| |||
2796 | 2806 |
| |
2797 | 2807 |
| |
2798 | 2808 |
| |
| 2809 | + | |
2799 | 2810 |
| |
2800 | 2811 |
| |
2801 | 2812 |
| |
| |||
2833 | 2844 |
| |
2834 | 2845 |
| |
2835 | 2846 |
| |
| 2847 | + | |
2836 | 2848 |
| |
2837 | 2849 |
| |
2838 | 2850 |
| |
| |||
2890 | 2902 |
| |
2891 | 2903 |
| |
2892 | 2904 |
| |
| 2905 | + | |
2893 | 2906 |
| |
2894 | 2907 |
| |
2895 | 2908 |
| |
| |||
2910 | 2923 |
| |
2911 | 2924 |
| |
2912 | 2925 |
| |
| 2926 | + | |
2913 | 2927 |
| |
2914 | 2928 |
| |
2915 | 2929 |
| |
| |||
3576 | 3590 |
| |
3577 | 3591 |
| |
3578 | 3592 |
| |
| 3593 | + | |
| 3594 | + | |
| 3595 | + | |
| 3596 | + | |
| 3597 | + | |
| 3598 | + | |
| 3599 | + | |
| 3600 | + | |
| 3601 | + | |
| 3602 | + | |
| 3603 | + | |
| 3604 | + | |
| 3605 | + | |
| 3606 | + | |
| 3607 | + | |
| 3608 | + | |
| 3609 | + | |
| 3610 | + | |
| 3611 | + | |
| 3612 | + | |
| 3613 | + | |
| 3614 | + | |
| 3615 | + | |
| 3616 | + | |
3579 | 3617 |
| |
3580 | 3618 |
| |
3581 | 3619 |
| |
|
0 commit comments