import json
# import requests
from urllib.request import urlopen
from dagster import asset, get_dagster_logger

@asset
def countries():
  """Master countries source"""
  url = "<http://localhost:5555/countries>"
  response = urlopen(url)
  data_json = json.loads(response.read())
  countries = [x for x in data_json]
  get_dagster_logger().info(f"Found {len(countries)} total countries in upstream dataset ")
  return countries