reqs

.gitlab-ci.yml

@@ -14,6 +14,7 @@ test:
     entrypoint: [""]
   before_script:
     - airflow db init
+    - pip install -r requirements.txt
   script: 
    - ls 
    - pwd

dags/b2shareoperator.py

 from airflow.models.baseoperator import BaseOperator
 from airflow.models.connection import Connection
+import requests
 
-        
+def get_objects(server):
+    lst = requests.get(urljoin(server, 'api/records')).json()
+    return lst['hits']['hits']
 
-from st import get_objects
 
 class B2ShareOperator(BaseOperator):
 

requirements.txt

+requests